Class StreamLoop<T>

Namespace

SodaFlow

Assembly

SodaFlow.dll

A forward reference for a Stream<T> equivalent to the Stream<T> it stands for.

[PublicAPI]
public class StreamLoop<T> : LoopedStream<T>

Type Parameters

T

The type of values fired by the stream loop.

Inheritance

object

Stream<T>

LoopedStream<T>

StreamLoop<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

LoopedStreamExtensionMethods.AsStream<T>(LoopedStream<T>)

MaybeExtensionMethods.ToMaybe<T>(T?)

UnitExtensionMethods.Ignore<T>(T)

UnitExtensionMethods.Upcast<T>(T)

AsyncStreamExtensions.MapAsync<TInput, TResult>(Stream<TInput>, StreamSink<TResult>, StreamSink<Exception>, MapAsyncOperation<TInput, TResult>, AsyncConcurrencyStrategyBase<Unit>, Stream<Unit>?, Stream<IReadOnlyCollection<TInput>>?, bool)

AsyncStreamExtensions.MapAsync<TInput, TResult, TStrategyInput>(Stream<TInput>, StreamSink<TResult>, StreamSink<Exception>, MapAsyncOperation<TInput, TResult>, AsyncConcurrencyStrategyBase<TStrategyInput>, Stream<Unit>?, Stream<IReadOnlyCollection<TInput>>?, bool)

AsyncStreamExtensions.MapAsync<TInput, TResult, TStrategyInput>(Stream<TInput>, StreamSink<TResult>, StreamSink<Exception>, MapAsyncOperation<TInput, TResult>, AsyncConcurrencyStrategyBase<TStrategyInput>, Func<TInput, TStrategyInput>, Stream<Unit>?, Stream<IReadOnlyCollection<TInput>>?, bool)

StreamExtensionMethods.AccumLazy<T, TReturn>(Stream<T>, Lazy<TReturn>, Func<T, TReturn, TReturn>)

StreamExtensionMethods.Accum<T, TReturn>(Stream<T>, TReturn, Func<T, TReturn, TReturn>)

StreamExtensionMethods.Calm<T>(Stream<T>)

StreamExtensionMethods.Calm<T>(Stream<T>, IEqualityComparer<T>)

StreamExtensionMethods.Calm<T>(Stream<T>, Func<T, T, bool>)

StreamExtensionMethods.Choose<T, TResult>(Stream<T>, Func<T, Maybe<TResult>>)

StreamExtensionMethods.CollectLazy<T, TState, TReturn>(Stream<T>, Lazy<TState>, Func<T, TState, (TReturn ReturnValue, TState State)>)

StreamExtensionMethods.Collect<T, TState, TReturn>(Stream<T>, TState, Func<T, TState, (TReturn ReturnValue, TState State)>)

StreamExtensionMethods.Debounce<T, TTime>(Stream<T>, ITimerSystem<TTime>, Func<TTime, TTime>)

StreamExtensionMethods.Filter<T>(Stream<T>, Func<T, bool>)

StreamExtensionMethods.Gate<T>(Stream<T>, Behavior<bool>)

StreamExtensionMethods.Gate<T>(Stream<T>, Cell<bool>)

StreamExtensionMethods.HoldLazy<T>(Stream<T>, Lazy<T>)

StreamExtensionMethods.Hold<T>(Stream<T>, T)

StreamExtensionMethods.ListenOnceAsync<T>(Stream<T>)

StreamExtensionMethods.ListenOnceAsync<T>(Stream<T>, CancellationToken)

StreamExtensionMethods.ListenOnceStrong<T>(Stream<T>, Action<T>)

StreamExtensionMethods.ListenOnce<T>(Stream<T>, Action<T>)

StreamExtensionMethods.ListenStrong<T>(Stream<T>, Action<T>)

StreamExtensionMethods.Listen<T>(Stream<T>, Action<T>)

StreamExtensionMethods.MapTo<T, TResult>(Stream<T>, TResult)

StreamExtensionMethods.Map<T, TResult>(Stream<T>, Func<T, TResult>)

StreamExtensionMethods.Merge<T>(Stream<T>, Stream<T>, Func<T, T, T>)

StreamExtensionMethods.Merge<T, T2>(Stream<T>, Stream<T2>)

StreamExtensionMethods.Merge<T, T2, T3>(Stream<T>, Stream<T2>, Stream<T3>)

StreamExtensionMethods.Merge<T, T2, T3, T4>(Stream<T>, Stream<T2>, Stream<T3>, Stream<T4>)

StreamExtensionMethods.Merge<T, T2, T3, T4, T5>(Stream<T>, Stream<T2>, Stream<T3>, Stream<T4>, Stream<T5>)

StreamExtensionMethods.Merge<T, T2, T3, T4, T5, T6>(Stream<T>, Stream<T2>, Stream<T3>, Stream<T4>, Stream<T5>, Stream<T6>)

StreamExtensionMethods.Merge<T, T2, T3, T4, T5, T6, T7>(Stream<T>, Stream<T2>, Stream<T3>, Stream<T4>, Stream<T5>, Stream<T6>, Stream<T7>)

StreamExtensionMethods.Merge<T, T2, T3, T4, T5, T6, T7, T8>(Stream<T>, Stream<T2>, Stream<T3>, Stream<T4>, Stream<T5>, Stream<T6>, Stream<T7>, Stream<T8>)

StreamExtensionMethods.Once<T>(Stream<T>)

StreamExtensionMethods.OrElse<T>(Stream<T>, Stream<T>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Behavior<T6>, Behavior<T7>, Behavior<T8>, Func<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Cell<T6>, Cell<T7>, Cell<T8>, Func<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>)

StreamExtensionMethods.SnapshotLatest<T, TResult>(Stream<T>, Behavior<TResult>)

StreamExtensionMethods.SnapshotLatest<T, TResult>(Stream<T>, Cell<TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, TResult>(Stream<T>, Behavior<T1>, Func<T, T1, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, TResult>(Stream<T>, Cell<T1>, Func<T, T1, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Func<T, T1, T2, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Func<T, T1, T2, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Func<T, T1, T2, T3, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Func<T, T1, T2, T3, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Func<T, T1, T2, T3, T4, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Func<T, T1, T2, T3, T4, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Func<T, T1, T2, T3, T4, T5, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Func<T, T1, T2, T3, T4, T5, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, T6, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Behavior<T6>, Func<T, T1, T2, T3, T4, T5, T6, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, T6, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Cell<T6>, Func<T, T1, T2, T3, T4, T5, T6, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, T6, T7, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Behavior<T6>, Behavior<T7>, Func<T, T1, T2, T3, T4, T5, T6, T7, TResult>)

StreamExtensionMethods.SnapshotLatest<T, T1, T2, T3, T4, T5, T6, T7, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Cell<T6>, Cell<T7>, Func<T, T1, T2, T3, T4, T5, T6, T7, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Behavior<T6>, Behavior<T7>, Behavior<T8>, Func<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Cell<T6>, Cell<T7>, Cell<T8>, Func<T, T1, T2, T3, T4, T5, T6, T7, T8, TResult>)

StreamExtensionMethods.Snapshot<T, TResult>(Stream<T>, Behavior<TResult>)

StreamExtensionMethods.Snapshot<T, TResult>(Stream<T>, Cell<TResult>)

StreamExtensionMethods.Snapshot<T, T1, TResult>(Stream<T>, Behavior<T1>, Func<T, T1, TResult>)

StreamExtensionMethods.Snapshot<T, T1, TResult>(Stream<T>, Cell<T1>, Func<T, T1, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Func<T, T1, T2, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Func<T, T1, T2, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Func<T, T1, T2, T3, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Func<T, T1, T2, T3, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Func<T, T1, T2, T3, T4, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Func<T, T1, T2, T3, T4, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Func<T, T1, T2, T3, T4, T5, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Func<T, T1, T2, T3, T4, T5, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, T6, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Behavior<T6>, Func<T, T1, T2, T3, T4, T5, T6, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, T6, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Cell<T6>, Func<T, T1, T2, T3, T4, T5, T6, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, T6, T7, TResult>(Stream<T>, Behavior<T1>, Behavior<T2>, Behavior<T3>, Behavior<T4>, Behavior<T5>, Behavior<T6>, Behavior<T7>, Func<T, T1, T2, T3, T4, T5, T6, T7, TResult>)

StreamExtensionMethods.Snapshot<T, T1, T2, T3, T4, T5, T6, T7, TResult>(Stream<T>, Cell<T1>, Cell<T2>, Cell<T3>, Cell<T4>, Cell<T5>, Cell<T6>, Cell<T7>, Func<T, T1, T2, T3, T4, T5, T6, T7, TResult>)

Constructors

StreamLoop()

Initializes a new instance of the StreamLoop<T> class, a forward reference to a stream with no definition at this point.

Methods

Loop(Stream<T>)

Resolve the loop to specify what the StreamLoop<T> was a forward reference to. This method must run in the same transaction as the one that made this StreamLoop<T> created and used. This needs an explicit transaction from Run<T>(Func<T>) or RunVoid(Action).