Export (0) Print
Expand All

Observable Class

Provides a set of static methods for query operations over observable sequences.

System.Object
  System.Reactive.Linq.Observable

Namespace:  System.Reactive.Linq
Assembly:  System.Reactive (in System.Reactive.dll)

'Declaration
<ExtensionAttribute> _
Public NotInheritable Class Observable
'Usage

The Observable type exposes the following members.

  NameDescription
Public methodStatic memberAggregate(Of TSource)(IObservable(Of TSource), Func(Of TSource, TSource, TSource))Applies an accumulator function over an observable sequence.
Public methodStatic memberAggregate(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.
Public methodStatic memberAll(Of TSource)Determines whether all elements of an observable sequence satisfies a condition.
Public methodStatic memberAmb(Of TSource)(IEnumerable(Of IObservable(Of TSource)))Propagates the observable sequence that reacts first with a specified sources.
Public methodStatic memberAmb(Of TSource)(IObservable(Of TSource)())Propagates the observable sequence that reacts first with a specified sources.
Public methodStatic memberAmb(Of TSource)(IObservable(Of TSource), IObservable(Of TSource))Propagates the observable sequence that reacts first with the specified first and second sequence.
Public methodStatic memberAnd(Of TLeft, TRight)Matches when both observable sequences have an available value.
Public methodStatic memberAny(Of TSource)(IObservable(Of TSource))Determines whether an observable sequence contains any elements.
Public methodStatic memberAny(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean))Determines whether all elements of an observable sequence satisfies a condition.
Public methodStatic memberAsObservable(Of TSource)Hides the identity of an observable sequence.
Public methodStatic memberAverage(IObservable(Of Decimal))Computes the average of an observable sequence of Decimal values.
Public methodStatic memberAverage(IObservable(Of Double))Computes the average of an observable sequence of Double values.
Public methodStatic memberAverage(IObservable(Of Int32))Computes the average of an observable sequence of Int32 values.
Public methodStatic memberAverage(IObservable(Of Int64))Computes the average of an observable sequence of Int64 values.
Public methodStatic memberAverage(IObservable(Of Nullable(Of Decimal)))Computes the average of an observable sequence of nullable Decimal values.
Public methodStatic memberAverage(IObservable(Of Nullable(Of Double)))Computes the average of an observable sequence of nullable Double values.
Public methodStatic memberAverage(IObservable(Of Nullable(Of Int32)))Computes the average of an observable sequence of nullable Int32 values.
Public methodStatic memberAverage(IObservable(Of Nullable(Of Int64)))Computes the average of an observable sequence of nullable Int64 values.
Public methodStatic memberAverage(IObservable(Of Nullable(Of Single)))Computes the average of an observable sequence of nullable Float values.
Public methodStatic memberAverage(IObservable(Of Single))Computes the average of an observable sequence of Float values.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(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.
Public methodStatic memberBuffer(Of TSource, TBufferClosing)(IObservable(Of TSource), Func(Of IObservable(Of TBufferClosing)))Indicates each element of an observable sequence into consecutive non-overlapping buffers.
Public methodStatic memberBuffer(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.
Public methodStatic memberCast(Of TResult)Converts the elements of an observable sequence to the specified type.
Public methodStatic memberCatch(Of TSource)(IEnumerable(Of IObservable(Of TSource)))Continues an observable sequence that is terminated by an exception with the next observable sequence.
Public methodStatic memberCatch(Of TSource)(IObservable(Of TSource)())Continues an observable sequence that is terminated by an exception with the next observable sequence.
Public methodStatic memberCatch(Of TSource)(IObservable(Of TSource), IObservable(Of TSource))Continues an observable sequence that is terminated by an exception with the next observable sequence.
Public methodStatic memberCatch(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.
Public methodStatic memberCombineLatest(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.
Public methodStatic memberConcat(Of TSource)(IEnumerable(Of IObservable(Of TSource)))Concatenates an enumerable sequence of observable sequences.
Public methodStatic memberConcat(Of TSource)(IObservable(Of IObservable(Of TSource)))Concatenates an observable sequence of observable sequences.
Public methodStatic memberConcat(Of TSource)(IObservable(Of TSource)())Concatenates all the observable sequences.
Public methodStatic memberConcat(Of TSource)(IObservable(Of TSource), IObservable(Of TSource))Concatenates two observable sequences.
Public methodStatic memberContains(Of TSource)(IObservable(Of TSource), TSource)Determines whether an observable sequence contains a specified element by using the default equality comparer.
Public methodStatic memberContains(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&lt;T&gt;.
Public methodStatic memberCount(Of TSource)Returns a Int32 that represents the total number of elements in an observable sequence.
Public methodStatic memberCreate(Of TSource)(Func(Of IObserver(Of TSource), Action))Creates an observable sequence from a specified subscribe method implementation with a specified subscribe.
Public methodStatic memberCreate(Of TSource)(Func(Of IObserver(Of TSource), IDisposable))Creates an observable sequence from a subscribe method implementation.
Public methodStatic memberDefaultIfEmpty(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.
Public methodStatic memberDefaultIfEmpty(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.
Public methodStatic memberDefer(Of TValue)Returns an observable sequence that invokes the observable factory whenever a new observer subscribes.
Public methodStatic memberDelay(Of TSource)(IObservable(Of TSource), DateTimeOffset)Indicates the observable sequence by due time with the specified source and dueTime.
Public methodStatic memberDelay(Of TSource)(IObservable(Of TSource), TimeSpan)Indicates the observable sequence by due time with the specified source and dueTime.
Public methodStatic memberDelay(Of TSource)(IObservable(Of TSource), DateTimeOffset, IScheduler)Indicates the observable sequence by due time with the specified source, dueTime and scheduler.
Public methodStatic memberDelay(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler)Indicates the observable sequence by due time with the specified source, dueTime and scheduler.
Public methodStatic memberDematerialize(Of TSource)Dematerializes the explicit notification values of an observable sequence as implicit notifications.
Public methodStatic memberDistinct(Of TSource)(IObservable(Of TSource))Returns an observable sequence that contains only distinct elements with a specified source.
Public methodStatic memberDistinct(Of TSource)(IObservable(Of TSource), IEqualityComparer(Of TSource))Returns an observable sequence that contains only distinct elements according to the comparer.
Public methodStatic memberDistinct(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Returns an observable sequence that contains only distinct elements according to the keySelector.
Public methodStatic memberDistinct(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.
Public methodStatic memberDistinctUntilChanged(Of TSource)(IObservable(Of TSource))Returns an observable sequence that contains only distinct contiguous elements with a specified source.
Public methodStatic memberDistinctUntilChanged(Of TSource)(IObservable(Of TSource), IEqualityComparer(Of TSource))Returns an observable sequence that contains only distinct contiguous elements according to the comparer.
Public methodStatic memberDistinctUntilChanged(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Returns an observable sequence that contains only distinct contiguous elements according to the keySelector.
Public methodStatic memberDistinctUntilChanged(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.
Public methodStatic memberDo(Of TSource)(IObservable(Of TSource), Action(Of TSource))Invokes an action for each element in the observable sequence.
Public methodStatic memberDo(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.
Public methodStatic memberDo(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.
Public methodStatic memberDo(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.
Public methodStatic memberDo(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.
Public methodStatic memberElementAt(Of TSource)Returns the element at a specified index in a sequence.
Public methodStatic memberElementAtOrDefault(Of TSource)Returns the element at a specified index in a sequence or a default value if the index is out of range.
Public methodStatic memberEmpty(Of TResult)Returns an empty observable sequence.
Public methodStatic memberEmpty(Of TResult)(IScheduler)Returns an empty observable sequence with the specified scheduler.
Public methodStatic memberFinally(Of TSource)Invokes a specified action after source observable sequence terminates normally or by an exception.
Public methodStatic memberFirst(Of TSource)(IObservable(Of TSource))Returns the first element of an observable sequence with a specified source.
Public methodStatic memberFirst(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean))Returns the first element of an observable sequence that matches the predicate.
Public methodStatic memberFirstOrDefault(Of TSource)(IObservable(Of TSource))Returns the first element of an observable sequence, or a default value if no value is found.
Public methodStatic memberFirstOrDefault(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.
Public methodStatic memberForEach(Of TSource)Invokes an action for each element in the observable sequence, and blocks until the sequence is terminated.
Public methodStatic memberFromAsyncPattern(Func(Of AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult))Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern(Of TResult)(Func(Of AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult))Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern(Of T1)(Func(Of T1, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult))Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(Of T1, TResult)(Func(Of T1, AsyncCallback, Object, IAsyncResult), Func(Of IAsyncResult, TResult))Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern(Of T1, T2)(Func(Of T1, T2, AsyncCallback, Object, IAsyncResult), Action(Of IAsyncResult))Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromAsyncPattern(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.
Public methodStatic memberFromEvent(Action(Of Action), Action(Of Action))Converts a .NET event to an observable sequence.
Public methodStatic memberFromEvent(Of TEventArgs)(Action(Of Action(Of TEventArgs)), Action(Of Action(Of TEventArgs)))Converts a .NET event to an observable sequence.
Public methodStatic memberFromEvent(Of TDelegate, TEventArgs)(Action(Of TDelegate), Action(Of TDelegate))Converts a .NET event to an observable sequence.
Public methodStatic memberFromEvent(Of TDelegate, TEventArgs)(Func(Of Action(Of TEventArgs), TDelegate), Action(Of TDelegate), Action(Of TDelegate))Converts a .NET event to an observable sequence.
Public methodStatic memberFromEventPattern(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.
Public methodStatic memberFromEventPattern(Object, String)Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find an instance event.
Public methodStatic memberFromEventPattern(Type, String)Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find a static event.
Public methodStatic memberFromEventPattern(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.
Public methodStatic memberFromEventPattern(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.
Public methodStatic memberFromEventPattern(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.
Public methodStatic memberFromEventPattern(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.
Public methodStatic memberFromEventPattern(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.
Public methodStatic memberGenerate(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.
Public methodStatic memberGenerate(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.
Public methodStatic memberGenerate(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.
Public methodStatic memberGenerate(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.
Public methodStatic memberGenerate(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.
Public methodStatic memberGenerate(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.
Public methodStatic memberGetEnumerator(Of TSource)Returns an enumerator that enumerates all values of the observable sequence.
Public methodStatic memberGroupBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Groups the elements of an observable sequence according to a specified key selector function.
Public methodStatic memberGroupBy(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.
Public methodStatic memberGroupBy(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.
Public methodStatic memberGroupBy(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.
Public methodStatic memberGroupByUntil(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.
Public methodStatic memberGroupByUntil(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.
Public methodStatic memberGroupByUntil(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.
Public methodStatic memberGroupByUntil(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.
Public methodStatic memberGroupJoin(Of TLeft, TRight, TLeftDuration, TRightDuration, TResult)Correlates the elements of two sequences based on overlapping durations, and groups the results.
Public methodStatic memberIgnoreElements(Of TSource)Ignores all values in an observable sequence leaving only the termination messages.
Public methodStatic memberInterval(TimeSpan)Returns an observable sequence that produces a value after each period.
Public methodStatic memberInterval(TimeSpan, IScheduler)Returns an observable sequence that produces a value after each period.
Public methodStatic memberJoin(Of TLeft, TRight, TLeftDuration, TRightDuration, TResult)Correlates the elements of two sequences based on overlapping durations.
Public methodStatic memberLast(Of TSource)(IObservable(Of TSource))Returns the last element of an observable sequence with a specified source.
Public methodStatic memberLast(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean))Returns the last element of an observable sequence that matches the predicate.
Public methodStatic memberLastOrDefault(Of TSource)(IObservable(Of TSource))Returns last element in the observable sequence, or a default value if no value is found.
Public methodStatic memberLastOrDefault(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.
Public methodStatic memberLatest(Of TSource)Samples the most recent value in an observable sequence.
Public methodStatic memberLongCount(Of TSource)Returns a Int64 that represents the total number of elements in an observable sequence.
Public methodStatic memberMaterialize(Of TSource)Materializes the implicit notifications of an observable sequence as explicit notification values.
Public methodStatic memberMax(IObservable(Of Decimal))Returns the maximum value in an observable sequence of Decimal values.
Public methodStatic memberMax(IObservable(Of Double))Returns the maximum value in an observable sequence of Double values.
Public methodStatic memberMax(IObservable(Of Int32))Returns the maximum value in an observable sequence of Int32 values.
Public methodStatic memberMax(IObservable(Of Int64))Returns the maximum value in an observable sequence of Int64 values.
Public methodStatic memberMax(IObservable(Of Nullable(Of Decimal)))Returns the maximum value in an observable sequence of nullable Decimal values.
Public methodStatic memberMax(IObservable(Of Nullable(Of Double)))Returns the maximum value in an observable sequence of nullable Double values.
Public methodStatic memberMax(IObservable(Of Nullable(Of Int32)))Returns the maximum value in an observable sequence of nullable Int32 values.
Public methodStatic memberMax(IObservable(Of Nullable(Of Int64)))Returns the maximum value in an observable sequence of nullable Int64 values.
Public methodStatic memberMax(IObservable(Of Nullable(Of Single)))Returns the maximum value in an observable sequence of nullable Float values.
Public methodStatic memberMax(IObservable(Of Single))Returns the maximum value in an observable sequence of Float values.
Public methodStatic memberMax(Of TSource)(IObservable(Of TSource))Returns the maximum element in an observable sequence.
Public methodStatic memberMax(Of TSource)(IObservable(Of TSource), IComparer(Of TSource))Returns the maximum value in an observable sequence according to the specified comparer.
Public methodStatic memberMaxBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Returns the elements in an observable sequence with the maximum key value.
Public methodStatic memberMaxBy(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.
Public methodStatic memberMerge(Of TSource)(IEnumerable(Of IObservable(Of TSource)))Merges an enumerable sequence of observable sequences into a single observable sequence.
Public methodStatic memberMerge(Of TSource)(IObservable(Of IObservable(Of TSource)))Merges an observable sequence of observable sequences into an observable sequence.
Public methodStatic memberMerge(Of TSource)(IObservable(Of TSource)())Merges all the observable sequences into a single observable sequence.
Public methodStatic memberMerge(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.
Public methodStatic memberMerge(Of TSource)(IEnumerable(Of IObservable(Of TSource)), IScheduler)Merges an enumerable sequence of observable sequences into a single observable sequence.
Public methodStatic memberMerge(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.
Public methodStatic memberMerge(Of TSource)(IObservable(Of TSource), IObservable(Of TSource))Merges an observable sequence of observable sequences into an observable sequence.
Public methodStatic memberMerge(Of TSource)(IScheduler, IObservable(Of TSource)())Merges all the observable sequences into a single observable sequence.
Public methodStatic memberMerge(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.
Public methodStatic memberMerge(Of TSource)(IObservable(Of TSource), IObservable(Of TSource), IScheduler)Merges two observable sequences into a single observable sequence.
Public methodStatic memberMin(IObservable(Of Decimal))Returns the minimum value in an observable sequence of Decimal values.
Public methodStatic memberMin(IObservable(Of Double))Returns the minimum value in an observable sequence of Double values.
Public methodStatic memberMin(IObservable(Of Int32))Returns the minimum value in an observable sequence of Int32 values.
Public methodStatic memberMin(IObservable(Of Int64))Returns the minimum value in an observable sequence of Int64 values.
Public methodStatic memberMin(IObservable(Of Nullable(Of Decimal)))Returns the minimum value in an observable sequence of nullable Decimal values.
Public methodStatic memberMin(IObservable(Of Nullable(Of Double)))Returns the minimum value in an observable sequence of nullable Double values.
Public methodStatic memberMin(IObservable(Of Nullable(Of Int32)))Returns the minimum value in an observable sequence of nullable Int32 values.
Public methodStatic memberMin(IObservable(Of Nullable(Of Int64)))Returns the minimum value in an observable sequence of nullable Int64 values.
Public methodStatic memberMin(IObservable(Of Nullable(Of Single)))Returns the minimum value in an observable sequence of nullable Float values.
Public methodStatic memberMin(IObservable(Of Single))Returns the minimum value in an observable sequence of Float values.
Public methodStatic memberMin(Of TSource)(IObservable(Of TSource))Returns the minimum element in an observable sequence.
Public methodStatic memberMin(Of TSource)(IObservable(Of TSource), IComparer(Of TSource))Returns the minimum value in an observable sequence according to the specified comparer.
Public methodStatic memberMinBy(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Returns the elements in an observable sequence with the minimum key value.
Public methodStatic memberMinBy(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.
Public methodStatic memberMostRecent(Of TSource)Samples the most recent value in an observable sequence.
Public methodStatic memberMulticast(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.
Public methodStatic memberMulticast(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.
Public methodStatic memberNever(Of TResult)Returns a non-terminating observable sequence.
Public methodStatic memberNext(Of TSource)Samples the next value (blocking without buffering) from in an observable sequence.
Public methodStatic memberObserveOn(Of TSource)(IObservable(Of TSource), IScheduler)Asynchronously notify observers on the specified scheduler.
Public methodStatic memberObserveOn(Of TSource)(IObservable(Of TSource), SynchronizationContext)Asynchronously notify observers on the specified synchronization context.
Public methodStatic memberOfType(Of TResult)Filters the elements of an observable sequence based on the specified type.
Public methodStatic memberOnErrorResumeNext(Of TSource)(IEnumerable(Of IObservable(Of TSource)))Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Public methodStatic memberOnErrorResumeNext(Of TSource)(IObservable(Of TSource)())Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Public methodStatic memberOnErrorResumeNext(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.
Public methodStatic memberPublish(Of TSource)(IObservable(Of TSource))Returns a connectable observable sequence that shares a single subscription to the underlying sequence.
Public methodStatic memberPublish(Of TSource)(IObservable(Of TSource), TSource)Returns a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initialValue.
Public methodStatic memberPublish(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.
Public methodStatic memberPublish(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.
Public methodStatic memberPublishLast(Of TSource)(IObservable(Of TSource))Returns a connectable observable sequence that shares a single subscription to the underlying sequence containing only the last notification.
Public methodStatic memberPublishLast(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.
Public methodStatic memberRange(Int32, Int32)Generates an observable sequence of integral numbers within a specified range.
Public methodStatic memberRange(Int32, Int32, IScheduler)Generates an observable sequence of integral numbers within a specified range.
Public methodStatic memberRefCount(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.
Public methodStatic memberRepeat(Of TSource)(IObservable(Of TSource))Repeats the observable sequence indefinitely.
Public methodStatic memberRepeat(Of TResult)(TResult)Generates an observable sequence that repeats the given element infinitely.
Public methodStatic memberRepeat(Of TSource)(IObservable(Of TSource), Int32)Repeats the observable sequence indefinitely.
Public methodStatic memberRepeat(Of TResult)(TResult, Int32)Generates an observable sequence that repeats the given element the specified number of times.
Public methodStatic memberRepeat(Of TResult)(TResult, IScheduler)Generates an observable sequence that repeats the given element infinitely.
Public methodStatic memberRepeat(Of TResult)(TResult, Int32, IScheduler)Generates an observable sequence that repeats the given element of the specified number of times.
Public methodStatic memberReplay(Of TSource)(IObservable(Of TSource))Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Public methodStatic memberReplay(Of TSource)(IObservable(Of TSource), Int32)Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Public methodStatic memberReplay(Of TSource)(IObservable(Of TSource), IScheduler)Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(Of TSource)(IObservable(Of TSource), Int32, IScheduler)Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberReplay(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.
Public methodStatic memberRetry(Of TSource)(IObservable(Of TSource))Repeats the source observable sequence until it successfully terminates.
Public methodStatic memberRetry(Of TSource)(IObservable(Of TSource), Int32)Repeats the source observable sequence until it successfully terminates.
Public methodStatic memberReturn(Of TResult)(TResult)Returns an observable sequence that contains a single element with a specified value.
Public methodStatic memberReturn(Of TResult)(TResult, IScheduler)Returns an observable sequence that contains a single value with a specified value and scheduler.
Public methodStatic memberSample(Of TSource)(IObservable(Of TSource), TimeSpan)Samples the observable sequence at each interval.
Public methodStatic memberSample(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler)Samples the observable sequence at each interval with the specified source, interval and scheduler.
Public methodStatic memberSample(Of TSource, TSample)(IObservable(Of TSource), IObservable(Of TSample))Samples the observable sequence at sampling ticks with the specified source and sampler.
Public methodStatic memberScan(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.
Public methodStatic memberScan(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.
Public methodStatic memberSelect(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.
Public methodStatic memberSelect(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.
Public methodStatic memberSelectMany(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.
Public methodStatic memberSelectMany(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.
Public methodStatic memberSelectMany(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.
Public methodStatic memberSelectMany(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.
Public methodStatic memberSelectMany(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.
Public methodStatic memberSelectMany(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.
Public methodStatic memberSequenceEqual(Of TSource)(IObservable(Of TSource), IObservable(Of TSource))Determines whether two sequences are equal by comparing the elements pairwise.
Public methodStatic memberSequenceEqual(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.
Public methodStatic memberSingle(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.
Public methodStatic memberSingle(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.
Public methodStatic memberSingleOrDefault(Of TSource)(IObservable(Of TSource))Returns the only element of an observable sequence, or a default value if the observable sequence is empty.
Public methodStatic memberSingleOrDefault(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.
Public methodStatic memberSkip(Of TSource)Bypasses a specified number of values in an observable sequence and then returns the remaining values.
Public methodStatic memberSkipLast(Of TSource)Bypasses a specified number of elements at the end of an observable sequence.
Public methodStatic memberSkipUntil(Of TSource, TOther)Returns the values from the source observable sequence only after the other observable sequence produces a value.
Public methodStatic memberSkipWhile(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.
Public methodStatic memberSkipWhile(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.
Public methodStatic memberStart(Action)Invokes the action asynchronously.
Public methodStatic memberStart(Action, IScheduler)Invokes the action asynchronously.
Public methodStatic memberStart(Of TSource)(Func(Of TSource))Invokes the function asynchronously.
Public methodStatic memberStart(Of TSource)(Func(Of TSource), IScheduler)Invokes the function asynchronously.
Public methodStatic memberStartWith(Of TSource)(IObservable(Of TSource), TSource())Prepends a sequence of values to an observable sequence with the specified source and values.
Public methodStatic memberStartWith(Of TSource)(IObservable(Of TSource), IScheduler, TSource())Prepends a sequence of values to an observable sequence with the specified source, scheduler and values.
Public methodStatic memberSubscribe(Of TSource)(IEnumerable(Of TSource), IObserver(Of TSource))Subscribes an observer to an enumerable sequence with the specified source and observer.
Public methodStatic memberSubscribe(Of TSource)(IEnumerable(Of TSource), IObserver(Of TSource), IScheduler)Subscribes an observer to an enumerable sequence with the specified source and observer.
Public methodStatic memberSubscribeOn(Of TSource)(IObservable(Of TSource), IScheduler)Asynchronously subscribes and unsubscribes observers on the specified scheduler.
Public methodStatic memberSubscribeOn(Of TSource)(IObservable(Of TSource), SynchronizationContext)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.
Public methodStatic memberSum(IObservable(Of Decimal))Computes the sum of a sequence of Decimal values.
Public methodStatic memberSum(IObservable(Of Double))Computes the sum of a sequence of Double values.
Public methodStatic memberSum(IObservable(Of Int32))Computes the sum of a sequence of Int32 values.
Public methodStatic memberSum(IObservable(Of Int64))Computes the sum of a sequence of Int64 values.
Public methodStatic memberSum(IObservable(Of Nullable(Of Decimal)))Computes the sum of a sequence of nullable Decimal values.
Public methodStatic memberSum(IObservable(Of Nullable(Of Double)))Computes the sum of a sequence of nullable Double values.
Public methodStatic memberSum(IObservable(Of Nullable(Of Int32)))Computes the sum of a sequence of nullable Int32 values.
Public methodStatic memberSum(IObservable(Of Nullable(Of Int64)))Computes the sum of a sequence of nullable Int64 values.
Public methodStatic memberSum(IObservable(Of Nullable(Of Single)))Computes the sum of a sequence of nullable Float values.
Public methodStatic memberSum(IObservable(Of Single))Computes the sum of a sequence of Float values.
Public methodStatic memberSwitch(Of TSource)Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Public methodStatic memberSynchronize(Of TSource)(IObservable(Of TSource))Synchronizes the observable sequence.
Public methodStatic memberSynchronize(Of TSource)(IObservable(Of TSource), Object)Synchronizes the observable sequence.
Public methodStatic memberTake(Of TSource)Returns a specified number of contiguous values from the start of an observable sequence.
Public methodStatic memberTakeLast(Of TSource)Returns a specified number of contiguous elements from the end of an observable sequence.
Public methodStatic memberTakeUntil(Of TSource, TOther)Returns the values from the source observable sequence until the other observable sequence produces a value.
Public methodStatic memberTakeWhile(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.
Public methodStatic memberTakeWhile(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.
Public methodStatic memberThen(Of TSource, TResult)Matches when the observable sequence has an available value and projects the value.
Public methodStatic memberThrottle(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.
Public methodStatic memberThrottle(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.
Public methodStatic memberThrow(Of TResult)(Exception)Returns an observable sequence that terminates with an exception.
Public methodStatic memberThrow(Of TResult)(Exception, IScheduler)Returns an observable sequence that terminates with an exception with the specified scheduler.
Public methodStatic memberTimeInterval(Of TSource)(IObservable(Of TSource))Records the time interval between consecutive values in an observable sequence with the specified source.
Public methodStatic memberTimeInterval(Of TSource)(IObservable(Of TSource), IScheduler)Records the time interval between consecutive values in an observable sequence with the specified source and scheduler.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), DateTimeOffset)Returns either the observable sequence or a TimeoutException if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), TimeSpan)Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), DateTimeOffset, IObservable(Of TSource))Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), DateTimeOffset, IScheduler)Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), TimeSpan, IObservable(Of TSource))Returns the source observable sequence or the other observable sequence if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), TimeSpan, IScheduler)Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), DateTimeOffset, IObservable(Of TSource), IScheduler)Returns the source observable sequence or the other observable sequence if dueTime elapses.
Public methodStatic memberTimeout(Of TSource)(IObservable(Of TSource), TimeSpan, IObservable(Of TSource), IScheduler)Returns the source observable sequence or the other observable sequence if dueTime elapses.
Public methodStatic memberTimer(DateTimeOffset)Returns an observable sequence that produces a value at due time.
Public methodStatic memberTimer(TimeSpan)Returns an observable sequence that produces a value after the due time has elapsed.
Public methodStatic memberTimer(DateTimeOffset, IScheduler)Returns an observable sequence that produces a value at due time.
Public methodStatic memberTimer(DateTimeOffset, TimeSpan)Returns an observable sequence that produces a value at due time and then after each period.
Public methodStatic memberTimer(TimeSpan, IScheduler)Returns an observable sequence that produces a value after the due time has elapsed.
Public methodStatic memberTimer(TimeSpan, TimeSpan)Returns an observable sequence that produces a value after due time has elapsed and then after each period.
Public methodStatic memberTimer(DateTimeOffset, TimeSpan, IScheduler)Returns an observable sequence that produces a value at due time and then after each period.
Public methodStatic memberTimer(TimeSpan, TimeSpan, IScheduler)Returns an observable sequence that produces a value after due time has elapsed and then each period.
Public methodStatic memberTimestamp(Of TSource)(IObservable(Of TSource))Records the timestamp for each value in an observable sequence with the specified source.
Public methodStatic memberTimestamp(Of TSource)(IObservable(Of TSource), IScheduler)Records the timestamp for each value in an observable sequence with the specified source and scheduler.
Public methodStatic memberToArray(Of TSource)Creates an array from an observable sequence.
Public methodStatic memberToAsync(Action)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Action, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of TSource)(Action(Of TSource))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of TResult)(Func(Of TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of TSource)(Action(Of TSource), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of TResult)(Func(Of TResult), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(Of T1, T2)(Action(Of T1, T2))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T, TResult)(Func(Of T, TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2)(Action(Of T1, T2), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T, TResult)(Func(Of T, TResult), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3)(Action(Of T1, T2, T3))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, TResult)(Func(Of T1, T2, TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3)(Action(Of T1, T2, T3), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, TResult)(Func(Of T1, T2, TResult), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4)(Action(Of T1, T2, T3, T4))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, TResult)(Func(Of T1, T2, T3, TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4)(Action(Of T1, T2, T3, T4), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, TResult)(Func(Of T1, T2, T3, TResult), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5)(Action(Of T1, T2, T3, T4, T5))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, TResult)(Func(Of T1, T2, T3, T4, TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5)(Action(Of T1, T2, T3, T4, T5), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, TResult)(Func(Of T1, T2, T3, T4, TResult), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5, T6)(Action(Of T1, T2, T3, T4, T5, T6))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5, TResult)(Func(Of T1, T2, T3, T4, T5, TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5, T6)(Action(Of T1, T2, T3, T4, T5, T6), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5, TResult)(Func(Of T1, T2, T3, T4, T5, TResult), IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5, T6, T7)(Action(Of T1, T2, T3, T4, T5, T6, T7))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(Of T1, T2, T3, T4, T5, T6, TResult)(Func(Of T1, T2, T3, T4, T5, T6, TResult))Converts the function into an asynchronous function.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToAsync(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.
Public methodStatic memberToDictionary(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Creates a dictionary from an observable sequence according to a specified key selector function.
Public methodStatic memberToDictionary(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.
Public methodStatic memberToDictionary(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.
Public methodStatic memberToDictionary(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.
Public methodStatic memberToEnumerable(Of TSource)Converts an observable sequence to an enumerable sequence.
Public methodStatic memberToEvent(IObservable(Of Unit))Exposes an observable sequence as an object with a .NET event with a specified source.
Public methodStatic memberToEvent(Of TSource)(IObservable(Of TSource))Exposes an observable sequence as an object with a .NET event with a specified source.
Public methodStatic memberToEventPattern(Of TEventArgs)Exposes an observable sequence as an object with a .NET event.
Public methodStatic memberToList(Of TSource)Creates a list from an observable sequence.
Public methodStatic memberToLookup(Of TSource, TKey)(IObservable(Of TSource), Func(Of TSource, TKey))Creates a lookup from an observable sequence according to a specified key selector function.
Public methodStatic memberToLookup(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.
Public methodStatic memberToLookup(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.
Public methodStatic memberToLookup(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.
Public methodStatic memberToObservable(Of TSource)(IEnumerable(Of TSource))Converts an enumerable sequence to an observable sequence with a specified source.
Public methodStatic memberToObservable(Of TSource)(IEnumerable(Of TSource), IScheduler)Converts an enumerable sequence to an observable sequence with a specified source and scheduler.
Public methodStatic memberUsing(Of TSource, TResource)Constructs an observable sequence that depends on a resource object.
Public methodStatic memberWhen(Of TResult)(IEnumerable(Of Plan(Of TResult)))Joins together the results from several patterns.
Public methodStatic memberWhen(Of TResult)(Plan(Of TResult)())Joins together the results from several patterns.
Public methodStatic memberWhere(Of TSource)(IObservable(Of TSource), Func(Of TSource, Boolean))Filters the elements of an observable sequence based on a predicate.
Public methodStatic memberWhere(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(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.
Public methodStatic memberWindow(Of TSource, TWindowClosing)(IObservable(Of TSource), Func(Of IObservable(Of TWindowClosing)))Projects each element of an observable sequence into consecutive non-overlapping windows.
Public methodStatic memberWindow(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.
Public methodStatic memberZip(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.
Public methodStatic memberZip(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.
Top

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.
Show:
© 2014 Microsoft