Sink.preMaterialize

Materializes this Sink, immediately returning (1) its materialized value, and (2) a new Sink that can be consume elements ‘into’ the pre-materialized one.

Sink operators

Signature

Sink.preMaterializeSink.preMaterialize

Description

Materializes this Sink, immediately returning (1) its materialized value, and (2) a new Sink that can be consume elements ‘into’ the pre-materialized one. Useful for when you need a materialized value of a Sink when handing it out to someone to materialize it for you.

Note that preMaterialize is implemented through a reactive streams Subscriber which means that a buffer is introduced and that errors are not propagated upstream but are turned into cancellations without error details.

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.