Click or drag to resize
Akka.NETSubFlowImplTIn, TOut, TMat, TClosed Class
TBD
Inheritance Hierarchy
SystemObject
  Akka.Streams.DslSubFlowTOut, TMat, TClosed
    Akka.Streams.ImplementationSubFlowImplTIn, TOut, TMat, TClosed

Namespace:  Akka.Streams.Implementation
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
Copy
public class SubFlowImpl<TIn, TOut, TMat, TClosed> : SubFlow<TOut, TMat, TClosed>

Type Parameters

TIn
TBD
TOut
TBD
TMat
TBD
TClosed
TBD

The SubFlowImplTIn, TOut, TMat, TClosed type exposes the following members.

Constructors
Properties
  NameDescription
Public propertyFlow
TBD
Top
Methods
  NameDescription
Public methodConcatSubstream
Flatten the sub-flows back into the super-flow by concatenating them. This is usually a bad idea when combined with GroupBy since it can easily lead to deadlock—the concatenation does not consume from the second substream until the first has finished and the GroupBy stage will get back-pressure from the second stream.
(Inherited from SubFlowTOut, TMat, TClosed.)
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 methodMapMaterializedValueTMat2(FuncTMat, TMat2)
TBD
(Inherited from SubFlowTOut, TMat, TClosed.)
Public methodMapMaterializedValueTMat2(FuncTMat, TMat2)
TBD
(Overrides SubFlowTOut, TMat, TClosedMapMaterializedValueTMat2(FuncTMat, TMat2).)
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Public methodMergeSubstreams
Flatten the sub-flows back into the super-flow by performing a merge without parallelism limit (i.e. having an unbounded number of sub-flows active concurrently).
(Inherited from SubFlowTOut, TMat, TClosed.)
Public methodMergeSubstreamsWithParallelism
TBD
(Overrides SubFlowTOut, TMat, TClosedMergeSubstreamsWithParallelism(Int32).)
Public methodRunWithTMat2(IGraphSinkShapeTOut, TMat2, IMaterializer)
Connect this SourceTOut, TMat to a SinkTIn, TMat and run it. The returned value is the materialized value of the SinkTIn, TMat, e.g. the IPublisher of a PublisherTIn.
(Inherited from SubFlowTOut, TMat, TClosed.)
Public methodRunWithTMat2(IGraphSinkShapeTOut, TMat2, IMaterializer)
TBD
(Overrides SubFlowTOut, TMat, TClosedRunWithTMat2(IGraphSinkShapeTOut, TMat2, IMaterializer).)
Public methodToTMat2(IGraphSinkShapeTOut, TMat2)
Attach a Sink to each sub-flow, closing the overall Graph that is being constructed.
(Inherited from SubFlowTOut, TMat, TClosed.)
Public methodToTMat2(IGraphSinkShapeTOut, TMat2)
TBD
(Overrides SubFlowTOut, TMat, TClosedToTMat2(IGraphSinkShapeTOut, TMat2).)
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Public methodViaT2, TMat2(IGraphFlowShapeTOut, T2, TMat2)
TBD
(Inherited from SubFlowTOut, TMat, TClosed.)
Public methodViaT2, TMat2(IGraphFlowShapeTOut, T2, TMat2)
TBD
(Overrides SubFlowTOut, TMat, TClosedViaT2, TMat2(IGraphFlowShapeTOut, T2, TMat2).)
Public methodViaMaterializedT2, TMat2, TMat3(IGraphFlowShapeTOut, T2, TMat2, FuncTMat, TMat2, TMat3)
TBD
(Inherited from SubFlowTOut, TMat, TClosed.)
Public methodViaMaterializedT2, TMat2, TMat3(IGraphFlowShapeTOut, T2, TMat2, FuncTMat, TMat2, TMat3)
TBD
(Overrides SubFlowTOut, TMat, TClosedViaMaterializedT2, TMat2, TMat3(IGraphFlowShapeTOut, T2, TMat2, FuncTMat, TMat2, TMat3).)
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