Class GraphStage<TShape>
A GraphStage represents a reusable graph stream processing stage. A GraphStage consists of a Shape which describes its input and output ports and a factory function that creates a GraphStageLogic which implements the processing logic that ties the ports together.
Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public abstract class GraphStage<TShape> : GraphStageWithMaterializedValue<TShape, NotUsed>, IGraphStageWithMaterializedValue<TShape, NotUsed>, IGraph<TShape, NotUsed>, IGraph<TShape> where TShape : Shape
Type Parameters
Name | Description |
---|---|
TShape | TBD |
Methods
| Improve this Doc View SourceCreateLogic(Attributes)
TBD
Declaration
protected abstract GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type | Name | Description |
---|---|---|
Attributes | inheritedAttributes | TBD |
Returns
Type | Description |
---|---|
GraphStageLogic | TBD |
CreateLogicAndMaterializedValue(Attributes)
TBD
Declaration
public sealed override ILogicAndMaterializedValue<NotUsed> CreateLogicAndMaterializedValue(Attributes inheritedAttributes)
Parameters
Type | Name | Description |
---|---|---|
Attributes | inheritedAttributes | TBD |
Returns
Type | Description |
---|---|
ILogicAndMaterializedValue<NotUsed> | TBD |
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<TShape, Akka.NotUsed>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)