Method Defer

Namespace

SodaFlow

Assembly

SodaFlow.dll

Defer<T>(Stream<T>)

Push each stream event onto a new transaction guaranteed to come before the next externally initiated transaction. Same as Split<T, TCollection>(Stream<TCollection>) but it works on a single value.

public static Stream<T> Defer<T>(Stream<T> s)

Parameters

s Stream<T>

The stream to defer.

Returns

Stream<T>

A stream firing the deferred event firings.

Type Parameters

T

The type of the stream to defer.