Click or drag to resize
Akka.NETFlowTIn, TOut, TMat Class
A FlowTIn, TOut, TMat is a set of stream processing steps that has one open input and one open output.
Inheritance Hierarchy
SystemObject
  Akka.Streams.DslFlowTIn, TOut, TMat

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
public sealed class Flow<TIn, TOut, TMat> : IFlow<TOut, TMat>, 
	IGraph<FlowShape<TIn, TOut>, TMat>, IGraph<FlowShape<TIn, TOut>>

Type Parameters

TIn
Type of the flow input.
TOut
Type of the flow output.
TMat
Type of value, flow graph may materialize to.

The FlowTIn, TOut, TMat type exposes the following members.

Properties
  NameDescription
Public propertyModule
TBD
Public propertyShape
TBD
Top
Methods
  NameDescription
Public methodAddAttributes
Add the given attributes to this FlowTIn, TOut, TMat. Further calls to WithAttributes(Attributes) will not remove these attributes. Note that this operation has no effect on an empty Flow (because the attributes apply only to the contained processing stages).
Public methodAsync
Put an asynchronous boundary around this Source.
Public methodConcatMaterializedTMat2, TMat3
Concatenate the given to this , meaning that once this Flow’s input is exhausted and all result elements have been generated, the Source’s elements will be produced. Note that the is materialized together with this Flow and just kept from producing elements by asserting back-pressure until its time comes. If this gets upstream error - no elements from the given will be pulled. @see . It is recommended to use the internally optimized LeftTLeft, TRight(TLeft, TRight) and RightTLeft, TRight(TLeft, TRight) combiners where appropriate instead of manually writing functions that pass through one of the values.
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Public methodJoinTMat2(IGraphFlowShapeTOut, TIn, TMat2)
Join this FlowTIn, TOut, TMat to another FlowTIn, TOut, TMat, by cross connecting the inputs and outputs, creating a IRunnableGraphTMat. The materialized value of the combined FlowTIn, TOut, TMat will be the materialized value of the current flow (ignoring the other Flow’s value), use JoinMaterializedTMat2, TMat3(IGraphFlowShapeTOut, TIn, TMat2, FuncTMat, TMat2, TMat3) if a different strategy is needed.
Public methodJoinTIn2, TOut2, TMat2(IGraphBidiShapeTOut, TOut2, TIn2, TIn, TMat2)
TBD
Public methodJoinMaterializedTMat2, TMat3(IGraphFlowShapeTOut, TIn, TMat2, FuncTMat, TMat2, TMat3)
Join this FlowTIn, TOut, TMat to another FlowTIn, TOut, TMat, by cross connecting the inputs and outputs, creating a IRunnableGraphTMat The combine function is used to compose the materialized values of this flow and that Flow into the materialized value of the resulting Flow.
Public methodJoinMaterializedTIn2, TOut2, TMat2, TMatRes(IGraphBidiShapeTOut, TOut2, TIn2, TIn, TMat2, FuncTMat, TMat2, TMatRes)
TBD
Public methodMapMaterializedValueTMat2
Transform the materialized value of this Flow, leaving all other properties as they were.
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Public methodNamed
Add a name attribute to this Flow.
Public methodRunWithTMat1, TMat2
Public methodToTMat2
Connect this FlowTIn, TOut, TMat to a SinkTIn, TMat, concatenating the processing steps of both. The materialized value of the combined SinkTIn, TMat will be the materialized value of the current flow (ignoring the given Sink’s value), use ToMaterializedTMat2, TMat3(IGraphSinkShapeTOut, TMat2, FuncTMat, TMat2, TMat3) if a different strategy is needed.
Public methodToMaterializedTMat2, TMat3
Connect this FlowTIn, TOut, TMat to a SinkTIn, TMat, concatenating the processing steps of both. The combine function is used to compose the materialized values of this flow and that Sink into the materialized value of the resulting Sink. It is recommended to use the internally optimized LeftTLeft, TRight(TLeft, TRight) and RightTLeft, TRight(TLeft, TRight) combiners where appropriate instead of manually writing functions that pass through one of the values.
Public methodToProcessor
Public methodToString
TBD
(Overrides ObjectToString.)
Public methodViaT2, TMat2
Transform this FlowTIn, TOut, TMat by appending the given processing steps. The materialized value of the combined FlowTIn, TOut, TMat will be the materialized value of the current flow (ignoring the other flow’s value), use ViaMaterializedTOut2, TMat2, TMat3(IGraphFlowShapeTOut, TOut2, TMat2, FuncTMat, TMat2, TMat3) if a different strategy is needed.
Public methodViaMaterializedTOut2, TMat2, TMat3
Transform this FlowTIn, TOut, TMat by appending the given processing steps. The combine function is used to compose the materialized values of this flow and that flow into the materialized value of the resulting Flow.
Public methodWithAttributes
Change the attributes of this FlowTIn, TOut, TMat to the given ones. Note that this operation has no effect on an empty Flow (because the attributes apply only to the contained processing stages).
Top
Extension Methods
See Also