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
| Edit this page 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 override sealed ILogicAndMaterializedValue<NotUsed> CreateLogicAndMaterializedValue(Attributes inheritedAttributes)
Parameters
Type | Name | Description |
---|---|---|
Attributes | inheritedAttributes | TBD |
Returns
Type | Description |
---|---|
ILogicAndMaterializedValue<NotUsed> | TBD |