SpringWebFlux FluxSink

Giriş

Şu satırı dahil ederiz

import reactor.core.publisher.DirectProcessor;
import reactor.core.publisher.Flux;
import reactor.core.publisher.FluxSink;
import reactor.core.scheduler.Schedulers;

Sanırım bir Sink asenkron programlama ile Reactor arasındaki köprüyü sağlıyor

constructor

Şöyle yaparız

DirectProcessor<Object> processor = DirectProcessor.create();
FluxSink<Object> sink processor.sink();