Show / Hide Table of Contents

Interface ISubscribable<T>

Represents a subscribable source.

Namespace: Reaqtive
Assembly: Reaqtive.Interfaces.dll
Syntax
public interface ISubscribable<out T> : IObservable<T>
Type Parameters
Name Description
T

Type of the elements produced by the subscribable source.

Methods

Subscribe(IObserver<T>)

Subscribes the specified observer to the subscribable source.

Declaration
ISubscription Subscribe(IObserver<T> observer)
Parameters
Type Name Description
System.IObserver<T> observer

Observer that will receive the elements of the source.

Returns
Type Description
ISubscription

Handle to the newly created subscription.

Extension Methods

Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Single>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Double>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)
Subscribable.Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Single>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Double>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)
Subscribable.Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Single>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Double>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)
Subscribable.Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Single>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Double>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)
Subscribable.Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)
Subscribable.Aggregate<TSource>(ISubscribable<TSource>, Func<TSource, TSource, TSource>)
Subscribable.Aggregate<TSource, TResult>(ISubscribable<TSource>, TResult, Func<TResult, TSource, TResult>)
Subscribable.Aggregate<TSource, TAccumulate, TResult>(ISubscribable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>)
Subscribable.All<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.Any<TSource>(ISubscribable<TSource>)
Subscribable.Any<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.Count<TSource>(ISubscribable<TSource>)
Subscribable.Count<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.IsEmpty<TSource>(ISubscribable<TSource>)
Subscribable.LongCount<TSource>(ISubscribable<TSource>)
Subscribable.LongCount<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.Scan<TSource>(ISubscribable<TSource>, Func<TSource, TSource, TSource>)
Subscribable.Scan<TSource, TResult>(ISubscribable<TSource>, TResult, Func<TResult, TSource, TResult>)
Subscribable.Max<TSource>(ISubscribable<TSource>)
Subscribable.Max<TSource>(ISubscribable<TSource>, IComparer<TSource>)
Subscribable.Min<TSource>(ISubscribable<TSource>)
Subscribable.Min<TSource>(ISubscribable<TSource>, IComparer<TSource>)
Subscribable.ToList<TSource>(ISubscribable<TSource>)
Subscribable.Merge<TSource>(ISubscribable<TSource>, ISubscribable<TSource>)
Subscribable.Do<TSource>(ISubscribable<TSource>, IObserver<TSource>)
Subscribable.Do<TSource>(ISubscribable<TSource>, Action<TSource>)
Subscribable.Do<TSource>(ISubscribable<TSource>, Action<TSource>, Action<Exception>)
Subscribable.Do<TSource>(ISubscribable<TSource>, Action<TSource>, Action)
Subscribable.Do<TSource>(ISubscribable<TSource>, Action<TSource>, Action<Exception>, Action)
Subscribable.Do<TSource, TNotification>(ISubscribable<TSource>, Func<TSource, TNotification>, IObserver<TNotification>)
Subscribable.Finally<TSource>(ISubscribable<TSource>, Action)
Subscribable.DistinctUntilChanged<TSource>(ISubscribable<TSource>)
Subscribable.DistinctUntilChanged<TSource>(ISubscribable<TSource>, IEqualityComparer<TSource>)
Subscribable.DistinctUntilChanged<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>)
Subscribable.DistinctUntilChanged<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
Subscribable.Sample<TSource, TSample>(ISubscribable<TSource>, ISubscribable<TSample>)
Subscribable.SkipUntil<TSource, TOther>(ISubscribable<TSource>, ISubscribable<TOther>)
Subscribable.TakeUntil<TSource, TOther>(ISubscribable<TSource>, ISubscribable<TOther>)
Subscribable.Throttle<TSource, TThrottle>(ISubscribable<TSource>, Func<TSource, ISubscribable<TThrottle>>)
Subscribable.Retry<TSource>(ISubscribable<TSource>)
Subscribable.Retry<TSource>(ISubscribable<TSource>, Int32)
Subscribable.StartWith<TSource>(ISubscribable<TSource>, TSource[])
Subscribable.FirstAsync<TSource>(ISubscribable<TSource>)
Subscribable.FirstAsync<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.FirstOrDefaultAsync<TSource>(ISubscribable<TSource>)
Subscribable.FirstOrDefaultAsync<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.GroupBy<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>)
Subscribable.GroupBy<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
Subscribable.GroupBy<TSource, TKey, TElement>(ISubscribable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)
Subscribable.GroupBy<TSource, TKey, TElement>(ISubscribable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>)
Subscribable.Select<TSource, TResult>(ISubscribable<TSource>, Func<TSource, TResult>)
Subscribable.Select<TSource, TResult>(ISubscribable<TSource>, Func<TSource, Int32, TResult>)
Subscribable.SelectMany<TSource, TResult>(ISubscribable<TSource>, Func<TSource, ISubscribable<TResult>>)
Subscribable.SelectMany<TSource, TCollection, TResult>(ISubscribable<TSource>, Func<TSource, ISubscribable<TCollection>>, Func<TSource, TCollection, TResult>)
Subscribable.SequenceEqual<TSource>(ISubscribable<TSource>, ISubscribable<TSource>)
Subscribable.SequenceEqual<TSource>(ISubscribable<TSource>, ISubscribable<TSource>, IEqualityComparer<TSource>)
Subscribable.Skip<TSource>(ISubscribable<TSource>, Int32)
Subscribable.SkipWhile<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.SkipWhile<TSource>(ISubscribable<TSource>, Func<TSource, Int32, Boolean>)
Subscribable.Take<TSource>(ISubscribable<TSource>, Int32)
Subscribable.TakeWhile<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.TakeWhile<TSource>(ISubscribable<TSource>, Func<TSource, Int32, Boolean>)
Subscribable.Where<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)
Subscribable.Where<TSource>(ISubscribable<TSource>, Func<TSource, Int32, Boolean>)
Subscribable.Buffer<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.Buffer<TSource>(ISubscribable<TSource>, TimeSpan, TimeSpan)
Subscribable.Buffer<TSource>(ISubscribable<TSource>, Int32)
Subscribable.Buffer<TSource>(ISubscribable<TSource>, Int32, Int32)
Subscribable.Buffer<TSource>(ISubscribable<TSource>, TimeSpan, Int32)
Subscribable.DelaySubscription<TSource>(ISubscribable<TSource>, DateTimeOffset)
Subscribable.DelaySubscription<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.Sample<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.Skip<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.SkipUntil<TSource>(ISubscribable<TSource>, DateTimeOffset)
Subscribable.Take<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.TakeUntil<TSource>(ISubscribable<TSource>, DateTimeOffset)
Subscribable.Throttle<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.Window<TSource>(ISubscribable<TSource>, TimeSpan)
Subscribable.Window<TSource>(ISubscribable<TSource>, TimeSpan, TimeSpan)
Subscribable.Window<TSource>(ISubscribable<TSource>, Int32)
Subscribable.Window<TSource>(ISubscribable<TSource>, Int32, Int32)
Subscribable.Window<TSource>(ISubscribable<TSource>, TimeSpan, Int32)
Subscribable.CombineLatest<TSource1, TSource2, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, Func<TSource1, TSource2, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, Func<TSource1, TSource2, TSource3, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, Func<TSource1, TSource2, TSource3, TSource4, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, ISubscribable<TSource14>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, ISubscribable<TSource14>, ISubscribable<TSource15>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>)
Subscribable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, ISubscribable<TSource14>, ISubscribable<TSource15>, ISubscribable<TSource16>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>)
TestSubscribableExtensions.Subscribe<T>(ISubscribable<T>, IObserver<T>, IOperatorContext)
TestSubscribableExtensions.Subscribe<T>(ISubscribable<T>, IObserver<T>, IOperatorContext, IOperatorStateContainer)
TestSubscribableExtensions.Apply<T>(ISubscribable<T>, TestScheduler, Recorded<SubscriptionAction>[])
TestSubscribableExtensions.Apply<T>(ISubscribable<T>, TestScheduler, Recorded<SubscriptionAction>)
In This Article
Back to top Generated by DocFX