Class SubFlowImpl<TIn, TOut, TMat, TClosed>
TBD
Implements
IFlow<TOut, TMat>
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public class SubFlowImpl<TIn, TOut, TMat, TClosed> : SubFlow<TOut, TMat, TClosed>, IFlow<TOut, TMat>Type Parameters
| Name | Description |
|---|---|
| TIn | TBD |
| TOut | TBD |
| TMat | TBD |
| TClosed | TBD |
Constructors
| Improve this Doc View SourceSubFlowImpl(Flow<TIn, TOut, TMat>, IMergeBack<TIn, TMat>, Func<Sink<TIn, TMat>, TClosed>)
TBD
Declaration
public SubFlowImpl(Flow<TIn, TOut, TMat> flow, IMergeBack<TIn, TMat> mergeBackFunction, Func<Sink<TIn, TMat>, TClosed> finishFunction)Parameters
| Type | Name | Description |
|---|---|---|
| Flow<TIn, TOut, TMat> | flow | TBD |
| IMergeBack<TIn, TMat> | mergeBackFunction | TBD |
| Func<Sink<TIn, TMat>, TClosed> | finishFunction | TBD |
Properties
| Improve this Doc View SourceFlow
TBD
Declaration
public Flow<TIn, TOut, TMat> Flow { get; }Property Value
| Type | Description |
|---|---|
| Flow<TIn, TOut, TMat> |
Methods
| Improve this Doc View SourceMapMaterializedValue<TMat2>(Func<TMat, TMat2>)
TBD
Declaration
public override IFlow<TOut, TMat2> MapMaterializedValue<TMat2>(Func<TMat, TMat2> mapFunc)Parameters
| Type | Name | Description |
|---|---|---|
| Func<TMat, TMat2> | mapFunc | TBD |
Returns
| Type | Description |
|---|---|
| IFlow<TOut, TMat2> | TBD |
Type Parameters
| Name | Description |
|---|---|
| TMat2 | TBD |
Overrides
Akka.Streams.Dsl.SubFlow<TOut, TMat, TClosed>.MapMaterializedValue<TMat2>(System.Func<TMat, TMat2>)
Exceptions
| Type | Condition |
|---|---|
| NotImplementedException | TBD |
MergeSubstreamsWithParallelism(Int32)
TBD
Declaration
public override IFlow<TOut, TMat> MergeSubstreamsWithParallelism(int parallelism)Parameters
| Type | Name | Description |
|---|---|---|
| Int32 | parallelism | TBD |
Returns
| Type | Description |
|---|---|
| IFlow<TOut, TMat> | TBD |
Overrides
Akka.Streams.Dsl.SubFlow<TOut, TMat, TClosed>.MergeSubstreamsWithParallelism(System.Int32)
|
Improve this Doc
View Source
RunWith<TMat2>(IGraph<SinkShape<TOut>, TMat2>, IMaterializer)
TBD
Declaration
public override TMat2 RunWith<TMat2>(IGraph<SinkShape<TOut>, TMat2> sink, IMaterializer materializer)Parameters
| Type | Name | Description |
|---|---|---|
| IGraph<SinkShape<TOut>, TMat2> | sink | TBD |
| IMaterializer | materializer | TBD |
Returns
| Type | Description |
|---|---|
| TMat2 | TBD |
Type Parameters
| Name | Description |
|---|---|
| TMat2 | TBD |
Overrides
Akka.Streams.Dsl.SubFlow<TOut, TMat, TClosed>.RunWith<TMat2>(Akka.Streams.IGraph<Akka.Streams.SinkShape<TOut>, TMat2>, Akka.Streams.IMaterializer)
Exceptions
| Type | Condition |
|---|---|
| NotImplementedException | TBD |
To<TMat2>(IGraph<SinkShape<TOut>, TMat2>)
TBD
Declaration
public override TClosed To<TMat2>(IGraph<SinkShape<TOut>, TMat2> sink)Parameters
| Type | Name | Description |
|---|---|---|
| IGraph<SinkShape<TOut>, TMat2> | sink | TBD |
Returns
| Type | Description |
|---|---|
| TClosed | TBD |
Type Parameters
| Name | Description |
|---|---|
| TMat2 | TBD |
Overrides
Akka.Streams.Dsl.SubFlow<TOut, TMat, TClosed>.To<TMat2>(Akka.Streams.IGraph<Akka.Streams.SinkShape<TOut>, TMat2>)
|
Improve this Doc
View Source
Via<T2, TMat2>(IGraph<FlowShape<TOut, T2>, TMat2>)
TBD
Declaration
public override IFlow<T2, TMat> Via<T2, TMat2>(IGraph<FlowShape<TOut, T2>, TMat2> flow)Parameters
| Type | Name | Description |
|---|---|---|
| IGraph<FlowShape<TOut, T2>, TMat2> | flow | TBD |
Returns
| Type | Description |
|---|---|
| IFlow<T2, TMat> | TBD |
Type Parameters
| Name | Description |
|---|---|
| T2 | TBD |
| TMat2 | TBD |
Overrides
Akka.Streams.Dsl.SubFlow<TOut, TMat, TClosed>.Via<T2, TMat2>(Akka.Streams.IGraph<Akka.Streams.FlowShape<TOut, T2>, TMat2>)
|
Improve this Doc
View Source
ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2>, Func<TMat, TMat2, TMat3>)
TBD
Declaration
public override IFlow<T2, TMat3> ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2> flow, Func<TMat, TMat2, TMat3> combine)Parameters
| Type | Name | Description |
|---|---|---|
| IGraph<FlowShape<TOut, T2>, TMat2> | flow | TBD |
| Func<TMat, TMat2, TMat3> | combine | TBD |
Returns
| Type | Description |
|---|---|
| IFlow<T2, TMat3> | TBD |
Type Parameters
| Name | Description |
|---|---|
| T2 | TBD |
| TMat2 | TBD |
| TMat3 | TBD |
Overrides
Akka.Streams.Dsl.SubFlow<TOut, TMat, TClosed>.ViaMaterialized<T2, TMat2, TMat3>(Akka.Streams.IGraph<Akka.Streams.FlowShape<TOut, T2>, TMat2>, System.Func<TMat, TMat2, TMat3>)
Exceptions
| Type | Condition |
|---|---|
| NotImplementedException | TBD |
WithAttributes(Attributes)
Change the attributes of this Flow<TIn, 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).
Declaration
public SubFlowImpl<TIn, TOut, TMat, TClosed> WithAttributes(Attributes attributes)Parameters
| Type | Name | Description |
|---|---|---|
| Attributes | attributes | TBD |
Returns
| Type | Description |
|---|---|
| SubFlowImpl<TIn, TOut, TMat, TClosed> | TBD |
Exceptions
| Type | Condition |
|---|---|
| NotSupportedException | TBD |
Improve this Doc