Class StreamSink<T>

Namespace

SodaFlow

Assembly

SodaFlow.Core.dll

A stream that lets a caller send values into it. It connects the world of I/O to the world of FRP. Code that supplies a stream sink for read access only must downcast it to Stream<T>.

[PublicAPI]
public class StreamSink<T> : Stream<T>

Type Parameters

T

The type of values fired by the stream sink.

Inheritance

object

Stream<T>

StreamSink<T>

Derived

CellStreamSink<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

MaybeExtensionMethods.ToMaybe<T>(T?)

UnitExtensionMethods.Ignore<T>(T)

UnitExtensionMethods.Upcast<T>(T)

StreamSinkExtensionMethods.AsStream<T>(StreamSink<T>)

StreamSinkExtensionMethods.Send<T>(StreamSink<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>)