Class ChannelSource

Container class for Akka.Streams Source<TOut, TMat> factory methods, which can be used to create sources from readable channels.

Inheritance
Object
ChannelSource
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public static class ChannelSource

Methods

| Improve this Doc View Source

Create<T>(Int32, Boolean, BoundedChannelFullMode)

Declaration
public static Source<T, ChannelWriter<T>> Create<T>(int bufferSize, bool singleWriter = false, BoundedChannelFullMode fullMode = BoundedChannelFullMode.Wait)
Parameters
Type Name Description
Int32 bufferSize
Boolean singleWriter
System.Threading.Channels.BoundedChannelFullMode fullMode
Returns
Type Description
Source<T, System.Threading.Channels.ChannelWriter<T>>
Type Parameters
Name Description
T
| Improve this Doc View Source

FromReader<T>(ChannelReader<T>)

Creates an Akka.Streams Source<TOut, TMat> from a given instance of System.Threading.Channels.ChannelReader<T>. It will propagate backpressure from the downstream to guarantee resource-safe communication as well as will react when reader will complete (successfully or with failure) and finish downstream accordingly.

Declaration
public static Source<T, NotUsed> FromReader<T>(ChannelReader<T> reader)
Parameters
Type Name Description
System.Threading.Channels.ChannelReader<T> reader
Returns
Type Description
Source<T, NotUsed>
Type Parameters
Name Description
T