Summary

ObservableExtensions.

Assembly

Rocket.Surgery.Reactive.Extensions.dll

Namespace

System.Reactive.Linq

Base Types

Object

graph BT Type-->Base0["Object"] Type["ObservableExtensions"] class Type type-node

Syntax

public static class ObservableExtensions

Attributes

Type	Description
NullableContextAttribute
NullableAttribute
PublicAPIAttribute

Methods

Name	Value	Summary
ConcatMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TCollection>>, Func<TSource, TCollection, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
ConcatMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TCollection>>, Func<TSource, int, TCollection, int, TResult>)	IObservable<TResult>	Merges elements from all inner observable sequences into a single observable sequence, limiting the number of concurrent subscriptions to inner sequences. static
ConcatMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TCollection>>, Func<TSource, int, TCollection, int, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
ConcatMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support and merges all of the task results into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence and concatenates the resulting enumerable sequences into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support and merges all of the task results into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence by incorporating the element's index and concatenates the resulting enumerable sequences into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index and merges the resulting observable sequences into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index and merges all of the task results into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence. static
ConcatMap<TSource, TResult>(IObservable<TSource>, Func<TSource, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task and merges all of the task results into one observable sequence. static
ConcatMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
ConcatMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
ConcatMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
ConcatMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
Debounce<T>(IObservable<T>, IObservable<Unit>, bool, bool, IScheduler)	IObservable<T>	Applies a debounce that will notify on either the leading and/or trailing edge. static
Debounce<T>(IObservable<T>, TimeSpan, bool, bool, IScheduler)	IObservable<T>	Applies a debounce that will notify on either the leading and/or trailing edge. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TCollection>>, Func<TSource, TCollection, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TCollection>>, Func<TSource, TCollection, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TCollection>>, Func<TSource, int, TCollection, int, TResult>)	IObservable<TResult>	Merges elements from all inner observable sequences into a single observable sequence, limiting the number of concurrent subscriptions to inner sequences. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TCollection>>, Func<TSource, int, TCollection, int, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TCollection>>, Func<TSource, int, TCollection, int, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
MergeMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence and concatenates the resulting enumerable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence and concatenates the resulting enumerable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence by incorporating the element's index and concatenates the resulting enumerable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence by incorporating the element's index and concatenates the resulting enumerable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index and merges the resulting observable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index and merges the resulting observable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, Task<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, Task<TResult>>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task and merges all of the task results into one observable sequence. static
MergeMap<TSource, TResult>(IObservable<TSource>, Func<TSource, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task and merges all of the task results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>, int)	IObservable<TResult>	Projects each element of an observable sequence to a task, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
MergeMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
RealThrottle<T>(IObservable<T>, IObservable<Unit>, bool, bool, IScheduler)	IObservable<T>	Applies a throttle that will notify on either the leading and/or trailing edge. static
RealThrottle<T>(IObservable<T>, TimeSpan, bool, bool, IScheduler)	IObservable<T>	Applies a throttle that will notify on either the leading and/or trailing edge. static
Reduce<TSource, TAccumulate, TResult>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>)	IObservable<TResult>	Applies an accumulator function over an observable sequence, returning the result of the aggregation as a single element in the result sequence. The specified seed value is used as the initial accumulator value, and the specified result selector function is used to select the result value. static
Reduce<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>)	IObservable<TAccumulate>	Applies an accumulator function over an observable sequence, returning the result of the aggregation as a single element in the result sequence. The specified seed value is used as the initial accumulator value. For aggregation behavior with incremental intermediate results, see System.Reactive.Linq.Observable.Scan``2(System.IObservable{``0},``1,System.Func{``1,``0,``1}). static
Reduce<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>)	IObservable<TSource>	Applies an accumulator function over an observable sequence, returning the result of the aggregation as a single element in the result sequence. For aggregation behavior with incremental intermediate results, see System.Reactive.Linq.Observable.Scan``1(System.IObservable{``0},System.Func{``0,``0,``0}). static
SwitchMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TCollection>>, Func<TSource, TCollection, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
SwitchMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TCollection>>, Func<TSource, int, TCollection, int, TResult>)	IObservable<TResult>	Merges elements from all inner observable sequences into a single observable sequence, limiting the number of concurrent subscriptions to inner sequences. static
SwitchMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TCollection>>, Func<TSource, int, TCollection, int, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
SwitchMap<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support and merges all of the task results into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence and concatenates the resulting enumerable sequences into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support and merges all of the task results into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IEnumerable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an enumerable sequence by incorporating the element's index and concatenates the resulting enumerable sequences into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, IObservable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence by incorporating the element's index and merges the resulting observable sequences into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, int, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index and merges all of the task results into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence. static
SwitchMap<TSource, TResult>(IObservable<TSource>, Func<TSource, Task<TResult>>)	IObservable<TResult>	Projects each element of an observable sequence to a task and merges all of the task results into one observable sequence. static
SwitchMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
SwitchMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, CancellationToken, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
SwitchMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, int, Task<TTaskResult>>, Func<TSource, int, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task by incorporating the element's index, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
SwitchMap<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)	IObservable<TResult>	Projects each element of an observable sequence to a task, invokes the result selector for the source element and the task result, and merges the results into one observable sequence. static
ToSignal<TSource>(IObservable<TSource>)	IObservable<Unit>	Returns a `System.Reactive.Unit` at the completion of an observable sequence. static
WhereNotNull<TSource>(IObservable<TSource>)	IObservable<TSource>	Applies a filter on an observable sequence returning only items from the sequence that are not null. static

ObservableExtensions Class

Summary

Syntax

Attributes

Methods