Spring webflux -连续发射器

Question

所以我有一个简单的方法

Flux<Task> getTaskToProcess();

我希望我的系统能源源不断地传输版权。现在我用旧的方式实现它，比如

while(!Thread.currentThread().isInterrupted()){
    getTaskToProcess().flatMap(....)
}

我非常确定这不是反应式方法的最佳方式。如何在工程反应堆中实现连续滴头？

Answer 1

尝试生成Flux#create或Flux#：

Flux<Task> tasks = Flux.create(sink -> {
  while(!Thread.currentThread().isInterrupted()) {
     sink.next(something);
  }
  sink.complete();
})
.subscribeOn(Schedulers.newSingle("stdin publisher"))