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 |
Edit this page