Click or drag to resize
Akka.NETStreamConvertersFromInputStream 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.129 (1.2.3.129)
Syntax
public static Source<ByteString, Task<IOResult>> FromInputStream(
	Func<Stream> createInputStream,
	int chunkSize = 8192
)

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, TaskIOResult
TBD
See Also