StreamConverters.asInputStream

Create a sink which materializes into an InputStream that can be read to trigger demand through the sink.

Additional Sink and Source converters

def asInputStream(readTimeout: FiniteDuration = 5.seconds): Sink[ByteString, InputStream]

Description

Create a sink which materializes into an InputStream that can be read to trigger demand through the sink. Bytes emitted through the stream will be available for reading through the InputStream

The InputStream will be ended when the stream flowing into this Sink completes, and the closing the InputStream will cancel the inflow of this Sink.