Method Split

Namespace

SodaFlow

Assembly

SodaFlow.dll

Split<T, TCollection>(Stream<TCollection>)

Push each stream event in the list of streams onto a new transaction, which always comes before the next transaction from other code. Two calls to this method can put stream events into the same new transaction. Thus, the events of the stream from this call can be simultaneous with the events from a Split<T, TCollection>(Stream<TCollection>) or a Defer<T>(Stream<T>) elsewhere.

public static Stream<T> Split<T, TCollection>(Stream<TCollection> s) where TCollection : IEnumerable<T>

Parameters

s Stream<TCollection>

The stream to split.

Returns

Stream<T>

A stream firing the split event firings.

Type Parameters

T

The collection item type of the stream to split.

TCollection

The collection type of the stream to split.