Class Buffer<T>

INTERNAL API

Inheritance
System.Object
GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>
GraphStage<FlowShape<T, T>>
SimpleLinearGraphStage<T>
Buffer<T>
Inherited Members
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Akka.Streams.Implementation.Fusing
Assembly: Akka.Streams.dll
Syntax
public sealed class Buffer<T> : SimpleLinearGraphStage<T>, IGraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>>
Type Parameters
Name Description
T

TBD

Constructors

| Improve this Doc View Source

Buffer(Int32, OverflowStrategy)

TBD

Declaration
public Buffer(int count, OverflowStrategy overflowStrategy)
Parameters
Type Name Description
System.Int32 count

TBD
OverflowStrategy overflowStrategy

TBD
Exceptions
Type Condition
System.NotSupportedException

This exception is thrown when the specified overflowStrategy has an unknown OverflowStrategy.

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes
Returns
Type Description
GraphStageLogic
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.FlowShape<T, T>>.CreateLogic(Akka.Streams.Attributes)

Extension Methods