| StreamConvertersAsInputStream Method |
Creates a Sink which when materialized will return an
Stream which it is possible
to read the values produced by the stream this Sink is attached to.
This Sink is intended for inter-operation with legacy APIs since it is inherently blocking.
You can configure the default dispatcher for this Source by changing the "akka.stream.blocking-io-dispatcher" or
set it for a given Source by using
CreateDispatcher(String).
The
Stream will be closed when the stream flowing into this
SinkTIn, TMat completes, and
closing the
Stream will cancel this
SinkTIn, TMat.
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax public static Sink<ByteString, Stream> AsInputStream(
Nullable<TimeSpan> readTimeout = null
)
static member AsInputStream :
?readTimeout : Nullable<TimeSpan>
(* Defaults:
let _readTimeout = defaultArg readTimeout null
*)
-> Sink<ByteString, Stream>
Parameters
- readTimeout (Optional)
- Type: SystemNullableTimeSpan
The max time the read operation on the materialized stream should block
Return Value
Type:
SinkByteString,
StreamTBD
See Also