Method CreateState

Namespace

SodaFlow.Async

Assembly

SodaFlow.Core.Async.dll

CreateState()

Makes a new scheduling state for one MapAsync call. The engine calls this one time for each call. See MapAsyncImpl<TInput, TResult, TStrategyInput>(Stream<TInput>, StreamSink<TResult>, StreamSink<Exception>, MapAsyncOperation<TInput, TResult>, AsyncConcurrencyStrategyBase<TStrategyInput>, Func<TInput, TStrategyInput>, Stream<UnitInternal>, Stream<IReadOnlyCollection<TInput>>, bool) Thus, two pipelines with the same strategy instance never read the state of the other, also when the two run at the same time.

protected abstract TState CreateState()

Returns

TState