Collect the value of Optional from all the elements passing through this flow , empty Optional is filtered out.

Simple operators




Streams the elements through the given future flow once it successfully completes. If the future fails the stream is failed.

Reactive Streams semantics

Emits when the current Optional’s value is present.

Backpressures when the value of the current Optional is present and downstream backpressures.

Completes when upstream completes.

Cancels when downstream cancels.

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.