Observable Class
Provides a set of static methods for query operations over observable sequences.
Namespace: System.Reactive.Linq
Assembly: System.Reactive (in System.Reactive.dll)
The Observable type exposes the following members.
| Name | Description | |
|---|---|---|
![]() ![]() | Aggregate(Of TSource)(IObservable(Of TSource), Func(Of TSource, TSource, TSource)) | Applies an accumulator function over an observable sequence. |
![]() ![]() | Aggregate(Of TSource, TAccumulate)(IObservable(Of TSource), TAccumulate, Func(Of TAccumulate, TSource, TAccumulate)) | Applies an accumulator function over an observable sequence with the specified seed value. |
![]() ![]() | All(Of TSource) | Determines whether all elements of an observable sequence satisfies a condition. |
![]() ![]() | Amb(Of TSource)(IEnumerable(Of IObservable(Of TSource))) | Propagates the observable sequence that reacts first with a specified sources. |
![]() ![]() | Amb(Of TSource)(IObservable(Of TSource)()) | Propagates the observable sequence that reacts first with a specified sources. |
![]() ![]() | Amb(Of TSource)(IObservable(Of TSource), IObservable(Of TSource)) | Propagates the observable sequence that reacts first with the specified first and second sequence. |
![]() ![]() | And(Of TLeft, TRight) | Matches when both observable sequences have an available value. |
![]() ![]() | Any(Of TSource)(IObservable(Of TSource)) | Determines whether an observable sequence contains any elements. |
![]() ![]() | Any(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Determines whether all elements of an observable sequence satisfies a condition. |
![]() ![]() | AsObservable(Of TSource) | Hides the identity of an observable sequence. |
![]() ![]() | Average(IObservable(Of Decimal)) | Computes the average of an observable sequence of Decimal values. |
![]() ![]() | Average(IObservable(Of Double)) | Computes the average of an observable sequence of Double values. |
![]() ![]() | Average(IObservable(Of Int32)) | Computes the average of an observable sequence of Int32 values. |
![]() ![]() | Average(IObservable(Of Int64)) | Computes the average of an observable sequence of Int64 values. |
![]() ![]() | Average(IObservable(Of Nullable(Of Decimal))) | Computes the average of an observable sequence of nullable Decimal values. |
![]() ![]() | Average(IObservable(Of Nullable(Of Double))) | Computes the average of an observable sequence of nullable Double values. |
![]() ![]() | Average(IObservable(Of Nullable(Of Int32))) | Computes the average of an observable sequence of nullable Int32 values. |
![]() ![]() | Average(IObservable(Of Nullable(Of Int64))) | Computes the average of an observable sequence of nullable Int64 values. |
![]() ![]() | Average(IObservable(Of Nullable(Of Single))) | Computes the average of an observable sequence of nullable Float values. |
![]() ![]() | Average(IObservable(Of Single)) | Computes the average of an observable sequence of Float values. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), Int32) | Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on element count information. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), TimeSpan) | Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on timing information. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), Int32, Int32) | Indicates each element of an observable sequence into zero or more buffers which are produced based on element count information. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), TimeSpan, Int32) | Indicates each element of an observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on timing information. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), TimeSpan, TimeSpan) | Indicates each element of an observable sequence into zero or more buffers which are produced based on timing information. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), TimeSpan, Int32, IScheduler) | Indicates each element of an observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed. |
![]() ![]() | Buffer(Of TSource)(IObservable(Of TSource), TimeSpan, TimeSpan, IScheduler) | Indicates each element of an observable sequence into zero or more buffers which are produced based on timing information. |
![]() ![]() | Buffer(Of TSource, TBufferClosing)(IObservable(Of TSource), Func(Of IObservable(Of TBufferClosing))) | Indicates each element of an observable sequence into consecutive non-overlapping buffers. |
![]() ![]() | Buffer(Of TSource, TBufferOpening, TBufferClosing)(IObservable(Of TSource), IObservable(Of TBufferOpening), Func(Of TBufferOpening, IObservable(Of TBufferClosing))) | Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers. |
![]() ![]() | Cast(Of TResult) | Converts the elements of an observable sequence to the specified type. |
![]() ![]() | Catch(Of TSource)(IEnumerable(Of IObservable(Of TSource))) | Continues an observable sequence that is terminated by an exception with the next observable sequence. |
![]() ![]() | Catch(Of TSource)(IObservable(Of TSource)()) | Continues an observable sequence that is terminated by an exception with the next observable sequence. |
![]() ![]() | Catch(Of TSource)(IObservable(Of TSource), IObservable(Of TSource)) | Continues an observable sequence that is terminated by an exception with the next observable sequence. |
![]() ![]() | Catch(Of TSource, TException)(IObservable(Of TSource), Func(Of TException, IObservable(Of TSource))) | Continues an observable sequence that is terminated by an exception of the specified type with the observable sequence produced by the handler. |
![]() ![]() | CombineLatest(Of TFirst, TSecond, TResult) | Merges two observable sequences into one observable sequence by using the selector function whenever one of the observable sequences produces an element. |
![]() ![]() | Concat(Of TSource)(IEnumerable(Of IObservable(Of TSource))) | Concatenates an enumerable sequence of observable sequences. |
![]() ![]() | Concat(Of TSource)(IObservable(Of IObservable(Of TSource))) | Concatenates an observable sequence of observable sequences. |
![]() ![]() | Concat(Of TSource)(IObservable(Of TSource)()) | Concatenates all the observable sequences. |
![]() ![]() | Concat(Of TSource)(IObservable(Of TSource), IObservable(Of TSource)) | Concatenates two observable sequences. |
![]() ![]() | Contains(Of TSource)(IObservable(Of TSource), TSource) | Determines whether an observable sequence contains a specified element by using the default equality comparer. |
![]() ![]() | Contains(Of TSource)(IObservable(Of TSource), TSource, IEqualityComparer(Of TSource)) | Determines whether an observable sequence contains a specified element by using a specified System.Collections.Generic.IEqualityComparer<T>. |
![]() ![]() | Count(Of TSource) | Returns a Int32 that represents the total number of elements in an observable sequence. |
![]() ![]() | Create(Of TSource)(Func(Of IObserver(Of TSource), Action)) | Creates an observable sequence from a specified subscribe method implementation with a specified subscribe. |
![]() ![]() | Create(Of TSource)(Func(Of IObserver(Of TSource), IDisposable)) | Creates an observable sequence from a subscribe method implementation. |
![]() ![]() | DefaultIfEmpty(Of TSource)(IObservable(Of TSource)) | Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty. |
![]() ![]() | DefaultIfEmpty(Of TSource)(IObservable(Of TSource), TSource) | Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty. |
![]() ![]() | Defer(Of TValue) | Returns an observable sequence that invokes the observable factory whenever a new observer subscribes. |
![]() ![]() | Delay(Of TSource)(IObservable(Of TSource), DateTimeOffset) | Indicates the observable sequence by due time with the specified source and dueTime. |
![]() ![]() | Delay(Of TSource)(IObservable(Of TSource), TimeSpan) | Indicates the observable sequence by due time with the specified source and dueTime. |
![]() ![]() | Delay(Of TSource)(IObservable(Of TSource), DateTimeOffset, IScheduler) | Indicates the observable sequence by due time with the specified source, dueTime and scheduler. |
![]() ![]() | Delay(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Indicates the observable sequence by due time with the specified source, dueTime and scheduler. |
![]() ![]() | Dematerialize(Of TSource) | Dematerializes the explicit notification values of an observable sequence as implicit notifications. |
![]() ![]() | Distinct(Of TSource)(IObservable(Of TSource)) | Returns an observable sequence that contains only distinct elements with a specified source. |
![]() ![]() | Distinct(Of TSource)(IObservable(Of TSource), IEqualityComparer(Of TSource)) | Returns an observable sequence that contains only distinct elements according to the comparer. |
![]() ![]() | Distinct(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Returns an observable sequence that contains only distinct elements according to the keySelector. |
![]() ![]() | Distinct(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IEqualityComparer(Of TKey)) | Returns an observable sequence that contains only distinct elements according to the keySelector. |
![]() ![]() | DistinctUntilChanged(Of TSource)(IObservable(Of TSource)) | Returns an observable sequence that contains only distinct contiguous elements with a specified source. |
![]() ![]() | DistinctUntilChanged(Of TSource)(IObservable(Of TSource), IEqualityComparer(Of TSource)) | Returns an observable sequence that contains only distinct contiguous elements according to the comparer. |
![]() ![]() | DistinctUntilChanged(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Returns an observable sequence that contains only distinct contiguous elements according to the keySelector. |
![]() ![]() | DistinctUntilChanged(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IEqualityComparer(Of TKey)) | Returns an observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer. |
![]() ![]() | Do(Of TSource)(IObservable(Of TSource), Action(Of TSource)) | Invokes an action for each element in the observable sequence. |
![]() ![]() | Do(Of TSource)(IObservable(Of TSource), IObserver(Of TSource)) | Invokes an action for each element in the observable sequence and invokes an action upon exceptional termination of the observable sequence. |
![]() ![]() | Do(Of TSource)(IObservable(Of TSource), Action(Of TSource), Action) | Invokes an action for each element in the observable sequence and invokes an action upon graceful termination of the observable sequence. |
![]() ![]() | Do(Of TSource)(IObservable(Of TSource), Action(Of TSource), Action(Of Exception)) | Invokes an action for each element in the observable sequence and invokes an action upon exceptional termination of the observable sequence. |
![]() ![]() | Do(Of TSource)(IObservable(Of TSource), Action(Of TSource), Action(Of Exception), Action) | Invokes an action for each element in the observable sequence, and invokes an action upon graceful or exceptional termination of the observable sequence. |
![]() ![]() | ElementAt(Of TSource) | Returns the element at a specified index in a sequence. |
![]() ![]() | ElementAtOrDefault(Of TSource) | Returns the element at a specified index in a sequence or a default value if the index is out of range. |
![]() ![]() | Empty(Of TResult) | Returns an empty observable sequence. |
![]() ![]() | Empty(Of TResult)(IScheduler) | Returns an empty observable sequence with the specified scheduler. |
![]() ![]() | Finally(Of TSource) | Invokes a specified action after source observable sequence terminates normally or by an exception. |
![]() ![]() | First(Of TSource)(IObservable(Of TSource)) | Returns the first element of an observable sequence with a specified source. |
![]() ![]() | First(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns the first element of an observable sequence that matches the predicate. |
![]() ![]() | FirstOrDefault(Of TSource)(IObservable(Of TSource)) | Returns the first element of an observable sequence, or a default value if no value is found. |
![]() ![]() | FirstOrDefault(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns the first element of an observable sequence that matches the predicate, or a default value if no value is found. |
![]() ![]() | ForEach(Of TSource) | Invokes an action for each element in the observable sequence, and blocks until the sequence is terminated. |
![]() ![]() | FromAsyncPattern(Func(Of AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of TResult)(Func(Of AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1)(Func(Of T1, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, TResult)(Func(Of T1, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2)(Func(Of T1, T2, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, TResult)(Func(Of T1, T2, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3)(Func(Of T1, T2, T3, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, TResult)(Func(Of T1, T2, T3, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4)(Func(Of T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, TResult)(Func(Of T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5)(Func(Of T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, TResult)(Func(Of T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6)(Func(Of T1, T2, T3, T4, T5, T6, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7)(Func(Of T1, T2, T3, T4, T5, T6, T7, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, TResult)(Func(Of T1, T2, T3, T4, T5, T6, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromAsyncPattern(Of T1, T2, T3, T4, T5, T6, T7, T8, T9)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult)) | Converts a Begin/End invoke function pair into an asynchronous function. |
![]() ![]() | FromEvent(Action(Of Action), Action(Of Action)) | Converts a .NET event to an observable sequence. |
![]() ![]() | FromEvent(Of TEventArgs)(Action(Of Action(Of TEventArgs)), Action(Of Action(Of TEventArgs))) | Converts a .NET event to an observable sequence. |
![]() ![]() | FromEvent(Of TDelegate, TEventArgs)(Action(Of TDelegate), Action(Of TDelegate)) | Converts a .NET event to an observable sequence. |
![]() ![]() | FromEvent(Of TDelegate, TEventArgs)(Func(Of Action(Of TEventArgs), TDelegate), Action(Of TDelegate), Action(Of TDelegate)) | Converts a .NET event to an observable sequence. |
![]() ![]() | FromEventPattern(Action(Of EventHandler), Action(Of EventHandler)) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with a specified add handler and remove handler. |
![]() ![]() | FromEventPattern(Object, String) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find an instance event. |
![]() ![]() | FromEventPattern(Type, String) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find a static event. |
![]() ![]() | FromEventPattern(Of TEventArgs)(Action(Of EventHandler(Of TEventArgs)), Action(Of EventHandler(Of TEventArgs))) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with the specified add handler and remove handler. |
![]() ![]() | FromEventPattern(Of TEventArgs)(Object, String) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find an instance event. |
![]() ![]() | FromEventPattern(Of TEventArgs)(Type, String) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find a static event. |
![]() ![]() | FromEventPattern(Of TDelegate, TEventArgs)(Action(Of TDelegate), Action(Of TDelegate)) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with the specified add handler and remove handler. |
![]() ![]() | FromEventPattern(Of TDelegate, TEventArgs)(Func(Of EventHandler(Of TEventArgs), TDelegate), Action(Of TDelegate), Action(Of TDelegate)) | Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with the specified conversion, add handler and remove handler. |
![]() ![]() | Generate(Of TState, TResult)(TState, Func(Of TState, Boolean), Func(Of TState, TState), Func(Of TState, TResult)) | Generates an observable sequence by iterating a state from an initial state until the condition fails. |
![]() ![]() | Generate(Of TState, TResult)(TState, Func(Of TState, Boolean), Func(Of TState, TState), Func(Of TState, TResult), Func(Of TState, DateTimeOffset)) | Generates an observable sequence by iterating a state from an initial state until the condition fails. |
![]() ![]() | Generate(Of TState, TResult)(TState, Func(Of TState, Boolean), Func(Of TState, TState), Func(Of TState, TResult), Func(Of TState, TimeSpan)) | Generates an observable sequence by iterating a state from an initial state until the condition fails. |
![]() ![]() | Generate(Of TState, TResult)(TState, Func(Of TState, Boolean), Func(Of TState, TState), Func(Of TState, TResult), IScheduler) | Generates an observable sequence by iterating a state from an initial state until the condition fails. |
![]() ![]() | Generate(Of TState, TResult)(TState, Func(Of TState, Boolean), Func(Of TState, TState), Func(Of TState, TResult), Func(Of TState, DateTimeOffset), IScheduler) | Generates an observable sequence by iterating a state from an initial state until the condition fails. |
![]() ![]() | Generate(Of TState, TResult)(TState, Func(Of TState, Boolean), Func(Of TState, TState), Func(Of TState, TResult), Func(Of TState, TimeSpan), IScheduler) | Generates an observable sequence by iterating a state from an initial state until the condition fails. |
![]() ![]() | GetEnumerator(Of TSource) | Returns an enumerator that enumerates all values of the observable sequence. |
![]() ![]() | GroupBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Groups the elements of an observable sequence according to a specified key selector function. |
![]() ![]() | GroupBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IEqualityComparer(Of TKey)) | Groups the elements of an observable sequence according to a specified key selector function and comparer. |
![]() ![]() | GroupBy(Of TSource, TKey, TElement)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement)) | Groups the elements of an observable sequence and selects the resulting elements by using a specified function. |
![]() ![]() | GroupBy(Of TSource, TKey, TElement)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement), IEqualityComparer(Of TKey)) | Groups the elements of an observable sequence according to a specified key selector function and comparer and selects the resulting elements by using a specified function. |
![]() ![]() | GroupByUntil(Of TSource, TKey, TDuration)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of IGroupedObservable(Of TKey, TSource), IObservable(Of TDuration))) | Groups the elements of an observable sequence according to a specified key selector function. |
![]() ![]() | GroupByUntil(Of TSource, TKey, TDuration)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of IGroupedObservable(Of TKey, TSource), IObservable(Of TDuration)), IEqualityComparer(Of TKey)) | Groups the elements of an observable sequence according to a specified key selector function and comparer. |
![]() ![]() | GroupByUntil(Of TSource, TKey, TElement, TDuration)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement), Func(Of IGroupedObservable(Of TKey, TElement), IObservable(Of TDuration))) | Groups the elements of an observable sequence according to a specified key selector function and selects the resulting elements by using a specified function. |
![]() ![]() | GroupByUntil(Of TSource, TKey, TElement, TDuration)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement), Func(Of IGroupedObservable(Of TKey, TElement), IObservable(Of TDuration)), IEqualityComparer(Of TKey)) | Groups the elements of an observable sequence according to a specified key selector function and comparer and selects the resulting elements by using a specified function. |
![]() ![]() | GroupJoin(Of TLeft, TRight, TLeftDuration, TRightDuration, TResult) | Correlates the elements of two sequences based on overlapping durations, and groups the results. |
![]() ![]() | IgnoreElements(Of TSource) | Ignores all values in an observable sequence leaving only the termination messages. |
![]() ![]() | Interval(TimeSpan) | Returns an observable sequence that produces a value after each period. |
![]() ![]() | Interval(TimeSpan, IScheduler) | Returns an observable sequence that produces a value after each period. |
![]() ![]() | Join(Of TLeft, TRight, TLeftDuration, TRightDuration, TResult) | Correlates the elements of two sequences based on overlapping durations. |
![]() ![]() | Last(Of TSource)(IObservable(Of TSource)) | Returns the last element of an observable sequence with a specified source. |
![]() ![]() | Last(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns the last element of an observable sequence that matches the predicate. |
![]() ![]() | LastOrDefault(Of TSource)(IObservable(Of TSource)) | Returns last element in the observable sequence, or a default value if no value is found. |
![]() ![]() | LastOrDefault(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns the last element of an observable sequence that matches the predicate, or a default value if no value is found. |
![]() ![]() | Latest(Of TSource) | Samples the most recent value in an observable sequence. |
![]() ![]() | LongCount(Of TSource) | Returns a Int64 that represents the total number of elements in an observable sequence. |
![]() ![]() | Materialize(Of TSource) | Materializes the implicit notifications of an observable sequence as explicit notification values. |
![]() ![]() | Max(IObservable(Of Decimal)) | Returns the maximum value in an observable sequence of Decimal values. |
![]() ![]() | Max(IObservable(Of Double)) | Returns the maximum value in an observable sequence of Double values. |
![]() ![]() | Max(IObservable(Of Int32)) | Returns the maximum value in an observable sequence of Int32 values. |
![]() ![]() | Max(IObservable(Of Int64)) | Returns the maximum value in an observable sequence of Int64 values. |
![]() ![]() | Max(IObservable(Of Nullable(Of Decimal))) | Returns the maximum value in an observable sequence of nullable Decimal values. |
![]() ![]() | Max(IObservable(Of Nullable(Of Double))) | Returns the maximum value in an observable sequence of nullable Double values. |
![]() ![]() | Max(IObservable(Of Nullable(Of Int32))) | Returns the maximum value in an observable sequence of nullable Int32 values. |
![]() ![]() | Max(IObservable(Of Nullable(Of Int64))) | Returns the maximum value in an observable sequence of nullable Int64 values. |
![]() ![]() | Max(IObservable(Of Nullable(Of Single))) | Returns the maximum value in an observable sequence of nullable Float values. |
![]() ![]() | Max(IObservable(Of Single)) | Returns the maximum value in an observable sequence of Float values. |
![]() ![]() | Max(Of TSource)(IObservable(Of TSource)) | Returns the maximum element in an observable sequence. |
![]() ![]() | Max(Of TSource)(IObservable(Of TSource), IComparer(Of TSource)) | Returns the maximum value in an observable sequence according to the specified comparer. |
![]() ![]() | MaxBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Returns the elements in an observable sequence with the maximum key value. |
![]() ![]() | MaxBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IComparer(Of TKey)) | Returns the elements in an observable sequence with the maximum key value. |
![]() ![]() | Merge(Of TSource)(IEnumerable(Of IObservable(Of TSource))) | Merges an enumerable sequence of observable sequences into a single observable sequence. |
![]() ![]() | Merge(Of TSource)(IObservable(Of IObservable(Of TSource))) | Merges an observable sequence of observable sequences into an observable sequence. |
![]() ![]() | Merge(Of TSource)(IObservable(Of TSource)()) | Merges all the observable sequences into a single observable sequence. |
![]() ![]() | Merge(Of TSource)(IEnumerable(Of IObservable(Of TSource)), Int32) | Merges an enumerable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences. |
![]() ![]() | Merge(Of TSource)(IEnumerable(Of IObservable(Of TSource)), IScheduler) | Merges an enumerable sequence of observable sequences into a single observable sequence. |
![]() ![]() | Merge(Of TSource)(IObservable(Of IObservable(Of TSource)), Int32) | Merges an enumerable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences. |
![]() ![]() | Merge(Of TSource)(IObservable(Of TSource), IObservable(Of TSource)) | Merges an observable sequence of observable sequences into an observable sequence. |
![]() ![]() | Merge(Of TSource)(IScheduler, IObservable(Of TSource)()) | Merges all the observable sequences into a single observable sequence. |
![]() ![]() | Merge(Of TSource)(IEnumerable(Of IObservable(Of TSource)), Int32, IScheduler) | Merges an enumerable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences. |
![]() ![]() | Merge(Of TSource)(IObservable(Of TSource), IObservable(Of TSource), IScheduler) | Merges two observable sequences into a single observable sequence. |
![]() ![]() | Min(IObservable(Of Decimal)) | Returns the minimum value in an observable sequence of Decimal values. |
![]() ![]() | Min(IObservable(Of Double)) | Returns the minimum value in an observable sequence of Double values. |
![]() ![]() | Min(IObservable(Of Int32)) | Returns the minimum value in an observable sequence of Int32 values. |
![]() ![]() | Min(IObservable(Of Int64)) | Returns the minimum value in an observable sequence of Int64 values. |
![]() ![]() | Min(IObservable(Of Nullable(Of Decimal))) | Returns the minimum value in an observable sequence of nullable Decimal values. |
![]() ![]() | Min(IObservable(Of Nullable(Of Double))) | Returns the minimum value in an observable sequence of nullable Double values. |
![]() ![]() | Min(IObservable(Of Nullable(Of Int32))) | Returns the minimum value in an observable sequence of nullable Int32 values. |
![]() ![]() | Min(IObservable(Of Nullable(Of Int64))) | Returns the minimum value in an observable sequence of nullable Int64 values. |
![]() ![]() | Min(IObservable(Of Nullable(Of Single))) | Returns the minimum value in an observable sequence of nullable Float values. |
![]() ![]() | Min(IObservable(Of Single)) | Returns the minimum value in an observable sequence of Float values. |
![]() ![]() | Min(Of TSource)(IObservable(Of TSource)) | Returns the minimum element in an observable sequence. |
![]() ![]() | Min(Of TSource)(IObservable(Of TSource), IComparer(Of TSource)) | Returns the minimum value in an observable sequence according to the specified comparer. |
![]() ![]() | MinBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Returns the elements in an observable sequence with the minimum key value. |
![]() ![]() | MinBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IComparer(Of TKey)) | Returns the elements in an observable sequence with the minimum key value according to the specified comparer. |
![]() ![]() | MostRecent(Of TSource) | Samples the most recent value in an observable sequence. |
![]() ![]() | Multicast(Of TSource, TResult)(IObservable(Of TSource), ISubject(Of TSource, TResult)) | Returns a connectable observable sequence that upon connection causes the source sequence to push results into the specified subject. |
![]() ![]() | Multicast(Of TSource, TIntermediate, TResult)(IObservable(Of TSource), Func(Of ISubject(Of TSource, TIntermediate)), Func(Of IObservable(Of TIntermediate), IObservable(Of TResult))) | Returns an observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function. |
![]() ![]() | Never(Of TResult) | Returns a non-terminating observable sequence. |
![]() ![]() | Next(Of TSource) | Samples the next value (blocking without buffering) from in an observable sequence. |
![]() ![]() | ObserveOn(Of TSource)(IObservable(Of TSource), IScheduler) | Asynchronously notify observers on the specified scheduler. |
![]() ![]() | ObserveOn(Of TSource)(IObservable(Of TSource), SynchronizationContext) | Asynchronously notify observers on the specified synchronization context. |
![]() ![]() | OfType(Of TResult) | Filters the elements of an observable sequence based on the specified type. |
![]() ![]() | OnErrorResumeNext(Of TSource)(IEnumerable(Of IObservable(Of TSource))) | Continues an observable sequence that is terminated normally or by an exception with the next observable sequence. |
![]() ![]() | OnErrorResumeNext(Of TSource)(IObservable(Of TSource)()) | Continues an observable sequence that is terminated normally or by an exception with the next observable sequence. |
![]() ![]() | OnErrorResumeNext(Of TSource)(IObservable(Of TSource), IObservable(Of TSource)) | Continues an observable sequence that is terminated normally or by an exception with the next observable sequence. |
![]() ![]() | Publish(Of TSource)(IObservable(Of TSource)) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence. |
![]() ![]() | Publish(Of TSource)(IObservable(Of TSource), TSource) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initialValue. |
![]() ![]() | Publish(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult))) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence. |
![]() ![]() | Publish(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), TSource) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initialValue. |
![]() ![]() | PublishLast(Of TSource)(IObservable(Of TSource)) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence containing only the last notification. |
![]() ![]() | PublishLast(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult))) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence containing only the last notification. |
![]() ![]() | Range(Int32, Int32) | Generates an observable sequence of integral numbers within a specified range. |
![]() ![]() | Range(Int32, Int32, IScheduler) | Generates an observable sequence of integral numbers within a specified range. |
![]() ![]() | RefCount(Of TSource) | Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence. |
![]() ![]() | Repeat(Of TSource)(IObservable(Of TSource)) | Repeats the observable sequence indefinitely. |
![]() ![]() | Repeat(Of TResult)(TResult) | Generates an observable sequence that repeats the given element infinitely. |
![]() ![]() | Repeat(Of TSource)(IObservable(Of TSource), Int32) | Repeats the observable sequence indefinitely. |
![]() ![]() | Repeat(Of TResult)(TResult, Int32) | Generates an observable sequence that repeats the given element the specified number of times. |
![]() ![]() | Repeat(Of TResult)(TResult, IScheduler) | Generates an observable sequence that repeats the given element infinitely. |
![]() ![]() | Repeat(Of TResult)(TResult, Int32, IScheduler) | Generates an observable sequence that repeats the given element of the specified number of times. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource)) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), Int32) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), IScheduler) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), TimeSpan) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), Int32, IScheduler) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), Int32, TimeSpan) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window. |
![]() ![]() | Replay(Of TSource)(IObservable(Of TSource), Int32, TimeSpan, IScheduler) | Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult))) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initial value. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), Int32) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), IScheduler) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), TimeSpan) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), Int32, IScheduler) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), Int32, TimeSpan) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), TimeSpan, IScheduler) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window. |
![]() ![]() | Replay(Of TSource, TResult)(IObservable(Of TSource), Func(Of IObservable(Of TSource), IObservable(Of TResult)), Int32, TimeSpan, IScheduler) | Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window. |
![]() ![]() | Retry(Of TSource)(IObservable(Of TSource)) | Repeats the source observable sequence until it successfully terminates. |
![]() ![]() | Retry(Of TSource)(IObservable(Of TSource), Int32) | Repeats the source observable sequence until it successfully terminates. |
![]() ![]() | Return(Of TResult)(TResult) | Returns an observable sequence that contains a single element with a specified value. |
![]() ![]() | Return(Of TResult)(TResult, IScheduler) | Returns an observable sequence that contains a single value with a specified value and scheduler. |
![]() ![]() | Sample(Of TSource)(IObservable(Of TSource), TimeSpan) | Samples the observable sequence at each interval. |
![]() ![]() | Sample(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Samples the observable sequence at each interval with the specified source, interval and scheduler. |
![]() ![]() | Sample(Of TSource, TSample)(IObservable(Of TSource), IObservable(Of TSample)) | Samples the observable sequence at sampling ticks with the specified source and sampler. |
![]() ![]() | Scan(Of TSource)(IObservable(Of TSource), Func(Of TSource, TSource, TSource)) | Applies an accumulator function over an observable sequence and returns each intermediate result with the specified source and accumulator. |
![]() ![]() | Scan(Of TSource, TAccumulate)(IObservable(Of TSource), TAccumulate, Func(Of TAccumulate, TSource, TAccumulate)) | Applies an accumulator function over an observable sequence and returns each intermediate result with the specified source, seed and accumulator. |
![]() ![]() | Select(Of TSource, TResult)(IObservable(Of TSource), Func(Of TSource, TResult)) | Projects each element of an observable sequence into a new form with the specified source and selector. |
![]() ![]() | Select(Of TSource, TResult)(IObservable(Of TSource), Func(Of TSource, Int32, TResult)) | Projects each element of an observable sequence into a new form by incorporating the element’s index with the specified source and selector. |
![]() ![]() | SelectMany(Of TSource, TResult)(IObservable(Of TSource), Func(Of TSource, IEnumerable(Of TResult))) | Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. |
![]() ![]() | SelectMany(Of TSource, TResult)(IObservable(Of TSource), Func(Of TSource, IObservable(Of TResult))) | Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. |
![]() ![]() | SelectMany(Of TSource, TOther)(IObservable(Of TSource), IObservable(Of TOther)) | Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. |
![]() ![]() | SelectMany(Of TSource, TResult)(IObservable(Of TSource), Func(Of TSource, IObservable(Of TResult)), Func(Of Exception, IObservable(Of TResult)), Func(Of IObservable(Of TResult))) | Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. |
![]() ![]() | SelectMany(Of TSource, TCollection, TResult)(IObservable(Of TSource), Func(Of TSource, IEnumerable(Of TCollection)), Func(Of TSource, TCollection, TResult)) | Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. |
![]() ![]() | SelectMany(Of TSource, TCollection, TResult)(IObservable(Of TSource), Func(Of TSource, IObservable(Of TCollection)), Func(Of TSource, TCollection, TResult)) | Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. |
![]() ![]() | SequenceEqual(Of TSource)(IObservable(Of TSource), IObservable(Of TSource)) | Determines whether two sequences are equal by comparing the elements pairwise. |
![]() ![]() | SequenceEqual(Of TSource)(IObservable(Of TSource), IObservable(Of TSource), IEqualityComparer(Of TSource)) | Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer. |
![]() ![]() | Single(Of TSource)(IObservable(Of TSource)) | Returns the only element of an observable sequence and throws an exception if there is not exactly one element in the observable sequence. |
![]() ![]() | Single(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns the only element of an observable sequence that matches the predicate and throws an exception if there is not exactly one element in the observable sequence. |
![]() ![]() | SingleOrDefault(Of TSource)(IObservable(Of TSource)) | Returns the only element of an observable sequence, or a default value if the observable sequence is empty. |
![]() ![]() | SingleOrDefault(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns the only element of an observable sequence that matches the predicate, or a default value if no value is found. |
![]() ![]() | Skip(Of TSource) | Bypasses a specified number of values in an observable sequence and then returns the remaining values. |
![]() ![]() | SkipLast(Of TSource) | Bypasses a specified number of elements at the end of an observable sequence. |
![]() ![]() | SkipUntil(Of TSource, TOther) | Returns the values from the source observable sequence only after the other observable sequence produces a value. |
![]() ![]() | SkipWhile(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Bypasses values in an observable sequence as long as a specified condition is true and then returns the remaining values. |
![]() ![]() | SkipWhile(Of TSource)(IObservable(Of TSource), Func(Of TSource, Int32, Boolean)) | Bypasses values in an observable sequence as long as a specified condition is true and then returns the remaining values. |
![]() ![]() | Start(Action) | Invokes the action asynchronously. |
![]() ![]() | Start(Action, IScheduler) | Invokes the action asynchronously. |
![]() ![]() | Start(Of TSource)(Func(Of TSource)) | Invokes the function asynchronously. |
![]() ![]() | Start(Of TSource)(Func(Of TSource), IScheduler) | Invokes the function asynchronously. |
![]() ![]() | StartWith(Of TSource)(IObservable(Of TSource), TSource()) | Prepends a sequence of values to an observable sequence with the specified source and values. |
![]() ![]() | StartWith(Of TSource)(IObservable(Of TSource), IScheduler, TSource()) | Prepends a sequence of values to an observable sequence with the specified source, scheduler and values. |
![]() ![]() | Subscribe(Of TSource)(IEnumerable(Of TSource), IObserver(Of TSource)) | Subscribes an observer to an enumerable sequence with the specified source and observer. |
![]() ![]() | Subscribe(Of TSource)(IEnumerable(Of TSource), IObserver(Of TSource), IScheduler) | Subscribes an observer to an enumerable sequence with the specified source and observer. |
![]() ![]() | SubscribeOn(Of TSource)(IObservable(Of TSource), IScheduler) | Asynchronously subscribes and unsubscribes observers on the specified scheduler. |
![]() ![]() | SubscribeOn(Of TSource)(IObservable(Of TSource), SynchronizationContext) | Asynchronously subscribes and unsubscribes observers on the specified synchronization context. |
![]() ![]() | Sum(IObservable(Of Decimal)) | Computes the sum of a sequence of Decimal values. |
![]() ![]() | Sum(IObservable(Of Double)) | Computes the sum of a sequence of Double values. |
![]() ![]() | Sum(IObservable(Of Int32)) | Computes the sum of a sequence of Int32 values. |
![]() ![]() | Sum(IObservable(Of Int64)) | Computes the sum of a sequence of Int64 values. |
![]() ![]() | Sum(IObservable(Of Nullable(Of Decimal))) | Computes the sum of a sequence of nullable Decimal values. |
![]() ![]() | Sum(IObservable(Of Nullable(Of Double))) | Computes the sum of a sequence of nullable Double values. |
![]() ![]() | Sum(IObservable(Of Nullable(Of Int32))) | Computes the sum of a sequence of nullable Int32 values. |
![]() ![]() | Sum(IObservable(Of Nullable(Of Int64))) | Computes the sum of a sequence of nullable Int64 values. |
![]() ![]() | Sum(IObservable(Of Nullable(Of Single))) | Computes the sum of a sequence of nullable Float values. |
![]() ![]() | Sum(IObservable(Of Single)) | Computes the sum of a sequence of Float values. |
![]() ![]() | Switch(Of TSource) | Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence. |
![]() ![]() | Synchronize(Of TSource)(IObservable(Of TSource)) | Synchronizes the observable sequence. |
![]() ![]() | Synchronize(Of TSource)(IObservable(Of TSource), Object) | Synchronizes the observable sequence. |
![]() ![]() | Take(Of TSource) | Returns a specified number of contiguous values from the start of an observable sequence. |
![]() ![]() | TakeLast(Of TSource) | Returns a specified number of contiguous elements from the end of an observable sequence. |
![]() ![]() | TakeUntil(Of TSource, TOther) | Returns the values from the source observable sequence until the other observable sequence produces a value. |
![]() ![]() | TakeWhile(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Returns values from an observable sequence as long as a specified condition is true, and then skips the remaining values. |
![]() ![]() | TakeWhile(Of TSource)(IObservable(Of TSource), Func(Of TSource, Int32, Boolean)) | Returns values from an observable sequence as long as a specified condition is true, and then skips the remaining values. |
![]() ![]() | Then(Of TSource, TResult) | Matches when the observable sequence has an available value and projects the value. |
![]() ![]() | Throttle(Of TSource)(IObservable(Of TSource), TimeSpan) | Ignores the values from an observable sequence which are followed by another value before due time with the specified source and dueTime. |
![]() ![]() | Throttle(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Ignores the values from an observable sequence which are followed by another value before due time with the specified source, dueTime and scheduler. |
![]() ![]() | Throw(Of TResult)(Exception) | Returns an observable sequence that terminates with an exception. |
![]() ![]() | Throw(Of TResult)(Exception, IScheduler) | Returns an observable sequence that terminates with an exception with the specified scheduler. |
![]() ![]() | TimeInterval(Of TSource)(IObservable(Of TSource)) | Records the time interval between consecutive values in an observable sequence with the specified source. |
![]() ![]() | TimeInterval(Of TSource)(IObservable(Of TSource), IScheduler) | Records the time interval between consecutive values in an observable sequence with the specified source and scheduler. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), DateTimeOffset) | Returns either the observable sequence or a TimeoutException if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), TimeSpan) | Returns either the observable sequence or an TimeoutException if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), DateTimeOffset, IObservable(Of TSource)) | Returns either the observable sequence or an TimeoutException if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), DateTimeOffset, IScheduler) | Returns either the observable sequence or an TimeoutException if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), TimeSpan, IObservable(Of TSource)) | Returns the source observable sequence or the other observable sequence if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Returns either the observable sequence or an TimeoutException if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), DateTimeOffset, IObservable(Of TSource), IScheduler) | Returns the source observable sequence or the other observable sequence if dueTime elapses. |
![]() ![]() | Timeout(Of TSource)(IObservable(Of TSource), TimeSpan, IObservable(Of TSource), IScheduler) | Returns the source observable sequence or the other observable sequence if dueTime elapses. |
![]() ![]() | Timer(DateTimeOffset) | Returns an observable sequence that produces a value at due time. |
![]() ![]() | Timer(TimeSpan) | Returns an observable sequence that produces a value after the due time has elapsed. |
![]() ![]() | Timer(DateTimeOffset, IScheduler) | Returns an observable sequence that produces a value at due time. |
![]() ![]() | Timer(DateTimeOffset, TimeSpan) | Returns an observable sequence that produces a value at due time and then after each period. |
![]() ![]() | Timer(TimeSpan, IScheduler) | Returns an observable sequence that produces a value after the due time has elapsed. |
![]() ![]() | Timer(TimeSpan, TimeSpan) | Returns an observable sequence that produces a value after due time has elapsed and then after each period. |
![]() ![]() | Timer(DateTimeOffset, TimeSpan, IScheduler) | Returns an observable sequence that produces a value at due time and then after each period. |
![]() ![]() | Timer(TimeSpan, TimeSpan, IScheduler) | Returns an observable sequence that produces a value after due time has elapsed and then each period. |
![]() ![]() | Timestamp(Of TSource)(IObservable(Of TSource)) | Records the timestamp for each value in an observable sequence with the specified source. |
![]() ![]() | Timestamp(Of TSource)(IObservable(Of TSource), IScheduler) | Records the timestamp for each value in an observable sequence with the specified source and scheduler. |
![]() ![]() | ToArray(Of TSource) | Creates an array from an observable sequence. |
![]() ![]() | ToAsync(Action) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Action, IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of TSource)(Action(Of TSource)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of TResult)(Func(Of TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of TSource)(Action(Of TSource), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of TResult)(Func(Of TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2)(Action(Of T1, T2)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T, TResult)(Func(Of T, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2)(Action(Of T1, T2), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T, TResult)(Func(Of T, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3)(Action(Of T1, T2, T3)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, TResult)(Func(Of T1, T2, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3)(Action(Of T1, T2, T3), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, TResult)(Func(Of T1, T2, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4)(Action(Of T1, T2, T3, T4)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, TResult)(Func(Of T1, T2, T3, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4)(Action(Of T1, T2, T3, T4), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, TResult)(Func(Of T1, T2, T3, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5)(Action(Of T1, T2, T3, T4, T5)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, TResult)(Func(Of T1, T2, T3, T4, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5)(Action(Of T1, T2, T3, T4, T5), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, TResult)(Func(Of T1, T2, T3, T4, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6)(Action(Of T1, T2, T3, T4, T5, T6)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, TResult)(Func(Of T1, T2, T3, T4, T5, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6)(Action(Of T1, T2, T3, T4, T5, T6), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, TResult)(Func(Of T1, T2, T3, T4, T5, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7)(Action(Of T1, T2, T3, T4, T5, T6, T7)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, TResult)(Func(Of T1, T2, T3, T4, T5, T6, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7)(Action(Of T1, T2, T3, T4, T5, T6, T7), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, TResult)(Func(Of T1, T2, T3, T4, T5, T6, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, TResult)) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, T9)(Action(Of T1, T2, T3, T4, T5, T6, T7, T8, T9), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToAsync(Of T1, T2, T3, T4, T5, T6, T7, T8, TResult)(Func(Of T1, T2, T3, T4, T5, T6, T7, T8, TResult), IScheduler) | Converts the function into an asynchronous function. |
![]() ![]() | ToDictionary(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Creates a dictionary from an observable sequence according to a specified key selector function. |
![]() ![]() | ToDictionary(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IEqualityComparer(Of TKey)) | Creates a dictionary from an observable sequence according to a specified key selector function, and a comparer. |
![]() ![]() | ToDictionary(Of TSource, TKey, TElement)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement)) | Creates a dictionary from an observable sequence according to a specified key selector function, and an element selector function. |
![]() ![]() | ToDictionary(Of TSource, TKey, TElement)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement), IEqualityComparer(Of TKey)) | Creates a dictionary from an observable sequence according to a specified key selector function, a comparer, and an element selector function. |
![]() ![]() | ToEnumerable(Of TSource) | Converts an observable sequence to an enumerable sequence. |
![]() ![]() | ToEvent(IObservable(Of Unit)) | Exposes an observable sequence as an object with a .NET event with a specified source. |
![]() ![]() | ToEvent(Of TSource)(IObservable(Of TSource)) | Exposes an observable sequence as an object with a .NET event with a specified source. |
![]() ![]() | ToEventPattern(Of TEventArgs) | Exposes an observable sequence as an object with a .NET event. |
![]() ![]() | ToList(Of TSource) | Creates a list from an observable sequence. |
![]() ![]() | ToLookup(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey)) | Creates a lookup from an observable sequence according to a specified key selector function. |
![]() ![]() | ToLookup(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey), IEqualityComparer(Of TKey)) | Creates a lookup from an observable sequence according to a specified key selector function, and a comparer. |
![]() ![]() | ToLookup(Of TSource, TKey, TElement)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement)) | Creates a lookup from an observable sequence according to a specified key selector function, and an element selector function. |
![]() ![]() | ToLookup(Of TSource, TKey, TElement)(IObservable(Of TSource), Func(Of TSource, TKey), Func(Of TSource, TElement), IEqualityComparer(Of TKey)) | Creates a lookup from an observable sequence according to a specified key selector function, a comparer, and an element selector function. |
![]() ![]() | ToObservable(Of TSource)(IEnumerable(Of TSource)) | Converts an enumerable sequence to an observable sequence with a specified source. |
![]() ![]() | ToObservable(Of TSource)(IEnumerable(Of TSource), IScheduler) | Converts an enumerable sequence to an observable sequence with a specified source and scheduler. |
![]() ![]() | Using(Of TSource, TResource) | Constructs an observable sequence that depends on a resource object. |
![]() ![]() | When(Of TResult)(IEnumerable(Of Plan(Of TResult))) | Joins together the results from several patterns. |
![]() ![]() | When(Of TResult)(Plan(Of TResult)()) | Joins together the results from several patterns. |
![]() ![]() | Where(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean)) | Filters the elements of an observable sequence based on a predicate. |
![]() ![]() | Where(Of TSource)(IObservable(Of TSource), Func(Of TSource, Int32, Boolean)) | Filters the elements of an observable sequence based on a predicate by incorporating the element's index. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), Int32) | Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on element count information. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), TimeSpan) | Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on timing information. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), Int32, Int32) | Projects each element of an observable sequence into zero or more windows which are produced based on element count information. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), TimeSpan, Int32) | Projects each element of an observable sequence into a window that is completed when either it’s full or a given amount of time has elapsed. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler) | Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on timing information. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), TimeSpan, TimeSpan) | Projects each element of an observable sequence into zero or more windows which are produced based on timing information. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), TimeSpan, Int32, IScheduler) | Projects each element of an observable sequence into a window that is completed when either it’s full or a given amount of time has elapsed. |
![]() ![]() | Window(Of TSource)(IObservable(Of TSource), TimeSpan, TimeSpan, IScheduler) | Projects each element of an observable sequence into zero or more windows which are produced based on timing information. |
![]() ![]() | Window(Of TSource, TWindowClosing)(IObservable(Of TSource), Func(Of IObservable(Of TWindowClosing))) | Projects each element of an observable sequence into consecutive non-overlapping windows. |
![]() ![]() | Window(Of TSource, TWindowOpening, TWindowClosing)(IObservable(Of TSource), IObservable(Of TWindowOpening), Func(Of TWindowOpening, IObservable(Of TWindowClosing))) | Projects each element of an observable sequence into zero or more windows. |
![]() ![]() | Zip(Of TFirst, TSecond, TResult)(IObservable(Of TFirst), IEnumerable(Of TSecond), Func(Of TFirst, TSecond, TResult)) | Merges an observable sequence and an enumerable sequence into one observable sequence by using the selector function. |
![]() ![]() | Zip(Of TFirst, TSecond, TResult)(IObservable(Of TFirst), IObservable(Of TSecond), Func(Of TFirst, TSecond, TResult)) | Merges two observable sequences into one observable sequence by combining their elements in a pairwise fashion. |
Show:
