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

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Streams.Dsl

Assembly: Akka.Streams.dll

Syntax

public static class ChannelSource

Methods

Create<T>(int, bool, BoundedChannelFullMode)

Declaration

public static Source<T, ChannelWriter<T>> Create<T>(int bufferSize, bool singleWriter = false, BoundedChannelFullMode fullMode = BoundedChannelFullMode.Wait)

Parameters

Type	Name	Description
int	bufferSize
bool	singleWriter
BoundedChannelFullMode	fullMode

Returns

Type	Description
Source<T, ChannelWriter<T>>

Type Parameters

Name	Description
T

FromReader<T>(ChannelReader<T>)

Creates an Akka.Streams Source<TOut, TMat> from a given instance of 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
ChannelReader<T>	reader

Returns

Type	Description
Source<T, NotUsed>

Type Parameters

Name	Description
T