Create a new accumulator from the given Sink.
Create a done accumulator.
Create a done accumulator.
The underlying sink will cancel as soon as its onSubscribe method is called, and the materialized value will be the passed in future.
Create a done accumulator.
Create a done accumulator.
The underlying sink will cancel as soon as its onSubscribe method is called, and the materialized value will be
an immediately available future of a
.
Flatten a future of an accumulator to an accumulator.
Create an accumulator that forwards the stream fed into it to the source it produces.
Create an accumulator that forwards the stream fed into it to the source it produces.
This is useful for when you want to send the consumed stream to another API that takes a Source as input.
Extreme care must be taken when using this accumulator - the source *must always* be materialized and consumed. If it isn't, this could lead to resource leaks and deadlocks upstream.
An accumulator that forwards the stream to the produced source.