Class Stream

Namespace

SodaFlow

Assembly

SodaFlow.dll

Helper methods for creating a Stream<T>.

[PublicAPI]
public static class Stream

Inheritance

object

Stream

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

CreateLoop<T>()

Makes a StreamLoop<T>. A caller must call this and close the loop in one transaction.

CreateSink<T>()

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

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.

Loop<T>()

Creates a helper to loop over a stream for the specified type.

Never<T>()

Creates a stream that never fires.