We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Motivation: Even currently, we have Source#unfold and Source#queue, which is still a bit different from the Reactor's Flux#create method.
Source#unfold
Source#queue,
Flux#create
When we want to control progress, we still make it lazy. btw, the behavior seems to be expressed with Source#lazySource and Source#queue.
I think the logic should not be that hard to implement but will make users' lives much easier.
refs: https://projectreactor.io/docs/core/release/reference/coreFeatures/programmatically-creating-sequence.html#producing.create
Flux<String> bridge = Flux.create(sink -> { myEventProcessor.register( new MyEventListener<String>() { public void onDataChunk(List<String> chunk) { for(String s : chunk) { sink.next(s); } } public void processComplete() { sink.complete(); } }); });
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Motivation:
Even currently, we have
Source#unfold
andSource#queue,
which is still a bit different from the Reactor'sFlux#create
method.When we want to control progress, we still make it lazy. btw, the behavior seems to be expressed with Source#lazySource and Source#queue.
I think the logic should not be that hard to implement but will make users' lives much easier.
refs: https://projectreactor.io/docs/core/release/reference/coreFeatures/programmatically-creating-sequence.html#producing.create
The text was updated successfully, but these errors were encountered: