Method CreateSink

Namespace

SodaFlow

Assembly

SodaFlow.dll

CreateSink<T>()

Creates a StreamSink that throws an exception if SodaFlow.Stream<T>.Send(SodaFlow.TransactionInternal, T) gets more than one time per transaction.

public static StreamSink<T> CreateSink<T>()

Returns

StreamSink<T>

Type Parameters

T

The type of values fired by the stream sink.

CreateSink<T>(Func<T, T, T>)

Makes a StreamSink that uses coalesce to put values together when SodaFlow.Stream<T>.Send(SodaFlow.TransactionInternal, T) gets more than one call in one transaction.

public static StreamSink<T> CreateSink<T>(Func<T, T, T> coalesce)

Parameters

coalesce Func<T, T, T>

Function to put values together when SodaFlow.Stream<T>.Send(SodaFlow.TransactionInternal, T) gets more than one call per transaction.

Returns

StreamSink<T>

Type Parameters

T

The type of values fired by the stream sink.