| StreamConvertersFromInputStream Method |
Creates a
SourceTOut, TMat from an
Stream created by the given function.
Emitted elements are
chunkSize sized
ByteString elements,
except the final element, which will be up to
chunkSize in size.
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).
It materializes a
TaskTResult of
IOResult containing the number of bytes read from the source file upon completion,
and a possible exception if IO operation was not completed successfully.
The created
Stream will be closed when the
SourceTOut, TMat is cancelled.
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax public static Source<ByteString, Task<IOResult>> FromInputStream(
Func<Stream> createInputStream,
int chunkSize = 8192
)
static member FromInputStream :
createInputStream : Func<Stream> *
?chunkSize : int
(* Defaults:
let _chunkSize = defaultArg chunkSize 8192
*)
-> Source<ByteString, Task<IOResult>>
Parameters
- createInputStream
- Type: SystemFuncStream
A function which creates the Stream to read from - chunkSize (Optional)
- Type: SystemInt32
The size of each read operation, defaults to 8192
Return Value
Type:
SourceByteString,
TaskIOResultTBD
See Also