Class SubFlowImpl<TIn, TOut, TMat, TClosed>

TBD

Inheritance

object

SubFlow<TOut, TMat, TClosed>

SubFlowImpl<TIn, TOut, TMat, TClosed>

Implements

IFlow<TOut, TMat>

Inherited Members

SubFlow<TOut, TMat, TClosed>.Via<T2, TMat2>(IGraph<FlowShape<TOut, T2>, TMat2>)

SubFlow<TOut, TMat, TClosed>.ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2>, Func<TMat, TMat2, TMat3>)

SubFlow<TOut, TMat, TClosed>.MapMaterializedValue<TMat2>(Func<TMat, TMat2>)

SubFlow<TOut, TMat, TClosed>.RunWith<TMat2>(IGraph<SinkShape<TOut>, TMat2>, IMaterializer)

SubFlow<TOut, TMat, TClosed>.To<TMat2>(IGraph<SinkShape<TOut>, TMat2>)

SubFlow<TOut, TMat, TClosed>.MergeSubstreams()

SubFlow<TOut, TMat, TClosed>.MergeSubstreamsWithParallelism(int)

SubFlow<TOut, TMat, TClosed>.ConcatSubstream()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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

SubFlowImpl(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

Flow

TBD

Declaration

public Flow<TIn, TOut, TMat> Flow { get; }

Property Value

Type	Description
Flow<TIn, TOut, TMat>

Methods

MapMaterializedValue<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

SubFlow<TOut, TMat, TClosed>.MapMaterializedValue<TMat2>(Func<TMat, TMat2>)

Exceptions

Type	Condition
NotImplementedException	TBD

MergeSubstreamsWithParallelism(int)

TBD

Declaration

public override IFlow<TOut, TMat> MergeSubstreamsWithParallelism(int parallelism)

Parameters

Type	Name	Description
int	parallelism	TBD

Returns

Type	Description
IFlow<TOut, TMat>	TBD

Overrides

SubFlow<TOut, TMat, TClosed>.MergeSubstreamsWithParallelism(int)

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

SubFlow<TOut, TMat, TClosed>.RunWith<TMat2>(IGraph<SinkShape<TOut>, TMat2>, 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

SubFlow<TOut, TMat, TClosed>.To<TMat2>(IGraph<SinkShape<TOut>, TMat2>)

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

SubFlow<TOut, TMat, TClosed>.ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2>, Func<TMat, TMat2, TMat3>)

Exceptions

Type	Condition
NotImplementedException	TBD

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

SubFlow<TOut, TMat, TClosed>.Via<T2, TMat2>(IGraph<FlowShape<TOut, T2>, TMat2>)

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

Implements

IFlow<TOut, TMat>

Extension Methods

SubFlowOperations.AggregateAsync<TIn, TOut, TMat, TClosed>(SubFlow<TIn, TMat, TClosed>, TOut, Func<TOut, TIn, Task<TOut>>)

SubFlowOperations.Aggregate<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, TOut2, Func<TOut2, TOut1, TOut2>)

SubFlowOperations.AlsoToMaterialized<TOut, TMat, TMat2, TMat3, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat2>, Func<TMat, TMat2, TMat3>)

SubFlowOperations.AlsoToMaterialized<TOut, TMat, TMat2, TMat3, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat2>, Func<TMat, TMat2, TMat3>, bool)

SubFlowOperations.AlsoTo<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat>)

SubFlowOperations.AlsoTo<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat>, bool)

SubFlowOperations.BackpressureTimeout<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.BatchWeighted<TOut, TOut2, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, long, Func<TOut, long>, Func<TOut, TOut2>, Func<TOut2, TOut, TOut2>)

SubFlowOperations.Batch<TOut, TOut2, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, long, Func<TOut, TOut2>, Func<TOut2, TOut, TOut2>)

SubFlowOperations.Buffer<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int, OverflowStrategy)

SubFlowOperations.Collect<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<TOut1, bool>?, Func<TOut1, TOut2>)

SubFlowOperations.Collect<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<TOut1, TOut2>)

SubFlowOperations.CompletionTimeout<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.ConcatMany<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<TOut1, IGraph<SourceShape<TOut2>, TMat>>)

SubFlowOperations.Concat<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SourceShape<TOut>, TMat>)

SubFlowOperations.ConflateWithSeed<TOut, TMat, TSeed, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<TOut, TSeed>, Func<TSeed, TOut, TSeed>)

SubFlowOperations.Conflate<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<TOut, TOut, TOut>)

SubFlowOperations.Delay<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan, DelayOverflowStrategy?)

SubFlowOperations.Detach<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>)

SubFlowOperations.DivertToMaterialized<TOut, TMat, TMat2, TMat3, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat2>, Func<TOut, bool>, Func<TMat, TMat2, TMat3>)

SubFlowOperations.DivertTo<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat>, Func<TOut, bool>)

SubFlowOperations.Expand<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<TOut1, IEnumerator<TOut2>>)

SubFlowOperations.GroupedWeightedWithin<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, long, int, TimeSpan, Func<TOut, long>)

SubFlowOperations.GroupedWithin<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int, TimeSpan)

SubFlowOperations.Grouped<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int)

SubFlowOperations.IdleTimeout<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.InitialDelay<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.InitialTimeout<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.InterleaveMaterialized<T1, T2, TMat, TMat2, TMat3, TClosed>(SubFlow<T1, TMat, TClosed>, IGraph<SourceShape<T2>, TMat2>, int, Func<TMat, TMat2, TMat3>)

SubFlowOperations.Interleave<T1, T2, TMat, TClosed>(SubFlow<T1, TMat, TClosed>, IGraph<SourceShape<T2>, TMat>, int)

SubFlowOperations.Intersperse<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TOut)

SubFlowOperations.Intersperse<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TOut, TOut, TOut)

SubFlowOperations.KeepAlive<TOut, TInjected, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan, Func<TInjected>)

SubFlowOperations.LimitWeighted<T, TMat, TClosed>(SubFlow<T, TMat, TClosed>, long, Func<T, long>)

SubFlowOperations.Limit<T, TMat, TClosed>(SubFlow<T, TMat, TClosed>, long)

SubFlowOperations.Log<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, string, Func<TOut, object>, ILoggingAdapter)

SubFlowOperations.MergeMany<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, int, Func<TOut1, IGraph<SourceShape<TOut2>, TMat>>)

SubFlowOperations.MergeMaterialized<TOut1, TOut2, TMat, TMat2, TMat3, TClosed>(SubFlow<TOut1, TMat, TClosed>, IGraph<SourceShape<TOut2>, TMat2>, Func<TMat, TMat2, TMat3>)

SubFlowOperations.MergeSorted<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SourceShape<TOut>, TMat>, IComparer<TOut>)

SubFlowOperations.MergeSorted<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SourceShape<TOut>, TMat>, Func<TOut, TOut, int>)

SubFlowOperations.Merge<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, IGraph<SourceShape<TOut2>, TMat>, bool)

SubFlowOperations.OrElse<T, TMat, TClosed>(SubFlow<T, TMat, TClosed>, IGraph<SourceShape<T>, TMat>)

SubFlowOperations.PrefixAndTail<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int)

SubFlowOperations.Prepend<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, IGraph<SourceShape<TOut2>, TMat>)

SubFlowOperations.RecoverWithRetries<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<Exception, IGraph<SourceShape<TOut>, TMat>>, int)

SubFlowOperations.RecoverWith<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<Exception, IGraph<SourceShape<TOut>, TMat>>)

SubFlowOperations.Recover<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<Exception, Option<TOut>>)

SubFlowOperations.ScanAsync<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, TOut2, Func<TOut2, TOut1, Task<TOut2>>)

SubFlowOperations.Scan<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, TOut2, Func<TOut2, TOut1, TOut2>)

SubFlowOperations.SelectAsyncUnordered<TIn, TOut, TMat, TClosed>(SubFlow<TIn, TMat, TClosed>, int, Func<TIn, Task<TOut>>)

SubFlowOperations.SelectAsync<TIn, TOut, TMat, TClosed>(SubFlow<TIn, TMat, TClosed>, int, Func<TIn, Task<TOut>>)

SubFlowOperations.SelectError<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<Exception, Exception>)

SubFlowOperations.SelectMany<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<TOut1, IEnumerable<TOut2>>)

SubFlowOperations.Select<TIn, TOut, TMat, TClosed>(SubFlow<TIn, TMat, TClosed>, Func<TIn, TOut>)

SubFlowOperations.SkipWhile<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Predicate<TOut>)

SubFlowOperations.SkipWithin<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.Skip<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, long)

SubFlowOperations.Sliding<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int, int)

SubFlowOperations.StatefulSelectMany<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<Func<TOut1, IEnumerable<TOut2>>>)

SubFlowOperations.Sum<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<TOut, TOut, TOut>)

SubFlowOperations.TakeWhile<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Predicate<TOut>, bool)

SubFlowOperations.TakeWithin<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, TimeSpan)

SubFlowOperations.Take<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, long)

SubFlowOperations.Throttle<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int, TimeSpan, int, ThrottleMode)

SubFlowOperations.Throttle<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, int, TimeSpan, int, Func<TOut, int>, ThrottleMode)

SubFlowOperations.Transform<TOut1, TOut2, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>, Func<IStage<TOut1, TOut2>>)

SubFlowOperations.WatchTermination<TOut, TMat, TMat2, TClosed>(SubFlow<TOut, TMat, TClosed>, Func<TMat, Task<Done>, TMat2>)

SubFlowOperations.WhereNot<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Predicate<TOut>)

SubFlowOperations.Where<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Predicate<TOut>)

SubFlowOperations.WireTap<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, IGraph<SinkShape<TOut>, TMat>)

SubFlowOperations.WireTap<TOut, TMat, TClosed>(SubFlow<TOut, TMat, TClosed>, Action<TOut>)

SubFlowOperations.ZipWithIndex<TOut1, TMat, TClosed>(SubFlow<TOut1, TMat, TClosed>)

SubFlowOperations.ZipWith<T1, T2, T3, TMat, TClosed>(SubFlow<T1, TMat, TClosed>, IGraph<SourceShape<T2>, TMat>, Func<T1, T2, T3>)

SubFlowOperations.Zip<T1, T2, TMat, TClosed>(SubFlow<T1, TMat, TClosed>, IGraph<SourceShape<T2>, TMat>)

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)