Qbservable class¶
Attributes: [ExcludeFromCodeCoverage]
Defined in
Namespace: System.Reactive.Linq
Assembly: System.Reactive.dll
Full name: System.Reactive.Linq.Qbservable
Modifiers: public static
Summary¶
Provides a set of static methods for writing queries over observable sequences, allowing translation to a target query language.
Applies to
netstandard2.0
Properties¶
| Name | Summary |
|---|---|
| static Provider | Gets the local query provider which will retarget Qbservable-based queries to the corresponding Observable-based query for in-memory execution upon subscription. |
Methods¶
| Name | Summary |
|---|---|
| static AsQbservable | Converts an in-memory observable sequence into an [IQbservable](# sequence with an expression tree representing the source sequence. |
| static AsObservable | Returns the input typed as an IObservable. This operator is used to separate the part of the query that's captured as an expression... |
| static ToQbservable | Converts an enumerable sequence to an observable sequence. |
| static Aggregate | 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... |
| static All | Determines whether all elements of an observable sequence satisfy a condition. |
| static Amb | Propagates the observable sequence that reacts first. |
| static Any | Determines whether an observable sequence contains any elements. |
| static Append | Append a value to an observable sequence. |
| static AutoConnect | Automatically connect the upstream IConnectableObservable at most once when the specified number of IObservers have subscribed to this IObservable. |
| static Average | Computes the average of an observable sequence of Decimal values. |
| static Buffer | Projects each element of an observable sequence into consecutive non-overlapping buffers which are produced based on element count information. |
| static ResetExceptionDispatchState | Propagates all messages, but if source produces an error, this updates the dispatch state of the Exception to reflect the current... |
| static Case | Uses selector to determine which source in sources to return, choosing an empty sequence if no match is found. |
| static Cast | Converts the elements of an observable sequence to the specified type. |
| static Catch | Continues an observable sequence that is terminated by an exception with the next observable sequence. |
| static Chunkify | Produces an enumerable sequence of consecutive (possibly empty) chunks of the source sequence. |
| static Collect | Produces an enumerable sequence that returns elements collected/aggregated from the source sequence between consecutive iterations. |
| static CombineLatest | Merges the specified observable sequences into one observable sequence by emitting a list with the latest source elements whenever any of the observable sequences produces an element. |
| static Concat | Concatenates the second observable sequence to the first observable sequence upon successful termination of the first. |
| static Contains | Determines whether an observable sequence contains a specified element by using the default equality comparer. |
| static Count | Returns an observable sequence containing an Int32 that represents the total number of elements in an observable sequence. |
| static Create | Creates an observable sequence from a specified Subscribe method implementation. |
| static DefaultIfEmpty | Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty. |
| static Defer | Returns an observable sequence that invokes the specified factory function whenever a new observer subscribes. |
| static DeferAsync | Returns an observable sequence that starts the specified cancellable asynchronous factory function whenever a new observer subscribes. The CancellationToken passed to the asynchronous... |
| static Delay | Time shifts the observable sequence to start propagating notifications at the specified absolute time. The relative time intervals between the values are preserved. |
| static DelaySubscription | Time shifts the observable sequence by delaying the subscription to the specified absolute time. |
| static Dematerialize | Dematerializes the explicit notification values of an observable sequence as implicit notifications. |
| static Distinct | Returns an observable sequence that contains only distinct elements. |
| static DistinctUntilChanged | Returns an observable sequence that contains only distinct contiguous elements. |
| static Do | Invokes the observer's methods for each message in the source sequence. This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run... |
| static DoWhile | Repeats the given source as long as the specified condition holds, where the condition is evaluated after each repeated source completed. |
| static ElementAt | Returns the element at a specified index in a sequence. |
| static ElementAtOrDefault | Returns the element at a specified index in a sequence or a default value if the index is out of range. |
| static Empty | Returns an empty observable sequence. |
| static Finally | Invokes a specified action after the source observable sequence terminates gracefully or exceptionally. |
| static FirstAsync | Returns the first element of an observable sequence. |
| static FirstOrDefaultAsync | Returns the first element of an observable sequence, or a default value if no such element exists. |
| static For | Concatenates the observable sequences obtained by running the resultSelector for each element in the given enumerable source. |
| static FromAsync | Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. |
| static FromEvent | Converts an Action-based .NET event to an observable sequence. Each event invocation is surfaced through an OnNext message in the resulting sequence. For conversion of events conforming... |
| static FromEventPattern | Converts a .NET event, conforming to the standard .NET event pattern based on EventHandler, to an observable sequence. Each event... |
| static Generate | Generates an observable sequence by running a state-driven loop producing the sequence's elements. |
| static GroupBy | Groups the elements of an observable sequence according to a specified key selector function. |
| static GroupByUntil | Groups the elements of an observable sequence according to a specified key selector function. A duration selector function is used to control the lifetime of groups. When a group... |
| static GroupJoin | Correlates the elements of two sequences based on overlapping durations, and groups the results. |
| static If | If the specified condition evaluates true, select the thenSource sequence. Otherwise, return an empty sequence. |
| static IgnoreElements | Ignores all elements in an observable sequence leaving only the termination messages. |
| static Interval | Returns an observable sequence that produces a value after each period. |
| static IsEmpty | Determines whether an observable sequence is empty. |
| static Join | Correlates the elements of two sequences based on overlapping durations. |
| static LastAsync | Returns the last element of an observable sequence. |
| static LastOrDefaultAsync | Returns the last element of an observable sequence, or a default value if no such element exists. |
| static Latest | Returns an enumerable sequence whose enumeration returns the latest observed element in the source observable sequence. Enumerators on the resulting sequence will never produce the same... |
| static LongCount | Returns an observable sequence containing an Int64 that represents the total number of elements in an observable sequence. |
| static Materialize | Materializes the implicit notifications of an observable sequence as explicit notification values. |
| static Max | Returns the maximum value in an observable sequence of Decimal values. |
| static MaxBy | Returns the elements in an observable sequence with the maximum key value. |
| static Merge | Merges elements from two observable sequences into a single observable sequence. |
| static Min | Returns the minimum value in an observable sequence of Decimal values. |
| static MinBy | Returns the elements in an observable sequence with the minimum key value. |
| static MostRecent | Returns an enumerable sequence whose enumeration returns the most recently observed element in the source observable sequence, using the specified initial value in case no element has been sampled... |
| static Multicast | Multicasts the source sequence notifications through an instantiated subject into all uses of the sequence within a selector function. Each subscription to the resulting sequence causes... |
| static Never | Returns a non-terminating observable sequence, which can be used to denote an infinite duration (e.g. when using reactive joins). |
| static Next | Returns an enumerable sequence whose enumeration blocks until the next element in the source observable sequence becomes available. Enumerators on the resulting sequence will block until... |
| static ObserveOn | Wraps the source sequence in order to run its observer callbacks on the specified synchronization context. |
| static OfType | Filters the elements of an observable sequence based on the specified type. |
| static OnErrorResumeNext | Concatenates the second observable sequence to the first observable sequence upon successful or exceptional termination of the first. |
| static Prepend | Prepend a value to an observable sequence. |
| static Publish | 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. This operator is a... |
| static PublishLast | 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... |
| static Range | Generates an observable sequence of integral numbers within a specified range. |
| static RefCount | Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence. |
| static Repeat | Generates an observable sequence that repeats the given element infinitely. |
| static RepeatWhen | Repeatedly resubscribes to the source observable after a normal completion and when the observable returned by a handler produces an arbitrary item. |
| static Replay | 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... |
| static Retry | Repeats the source observable sequence until it successfully terminates. |
| static RetryWhen | Retries (resubscribes to) the source observable after a failure and when the observable returned by a handler produces an arbitrary item. |
| static Return | Returns an observable sequence that contains a single element. |
| static Sample | Samples the observable sequence at each interval. Upon each sampling tick, the latest element (if any) in the source sequence during the last sampling interval is sent to the resulting... |
| static Scan | Applies an accumulator function over an observable sequence and returns each intermediate result. For aggregation behavior with no intermediate results, see... |
| static Select | Projects each element of an observable sequence into a new form. |
| static SelectMany | 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... |
| static SequenceEqual | Determines whether two sequences are equal by comparing the elements pairwise. |
| static SingleAsync | Returns the only element of an observable sequence, and reports an exception if there is not exactly one element in the observable sequence. |
| static SingleOrDefaultAsync | Returns the only element of an observable sequence, or a default value if the observable sequence is empty; this method reports an exception if there is more than one element in the observable... |
| static Skip | Bypasses a specified number of elements in an observable sequence and then returns the remaining elements. |
| static SkipLast | Bypasses a specified number of elements at the end of an observable sequence. |
| static SkipUntil | Skips elements from the observable source sequence until the specified start time. |
| static SkipWhile | Bypasses elements in an observable sequence as long as a specified condition is true and then returns the remaining elements. |
| static Start | Invokes the action asynchronously, surfacing the result through an observable sequence. |
| static StartAsync | Invokes the asynchronous action, surfacing the result through an observable sequence. |
| static StartWith | Prepends a sequence of values to an observable sequence. |
| static SubscribeOn | Wraps the source sequence in order to run its subscription and unsubscription logic on the specified synchronization context. This operation is not commonly used; see the remarks section... |
| static Sum | Computes the sum of a sequence of Decimal values. |
| static Switch | Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence. Each time a new inner... |
| static Synchronize | Synchronizes the observable sequence such that observer notifications cannot be delivered concurrently. This overload is useful to "fix" an observable sequence that exhibits concurrent... |
| static Take | Returns a specified number of contiguous elements from the start of an observable sequence. |
| static TakeLast | Returns a specified number of contiguous elements from the end of an observable sequence. |
| static TakeLastBuffer | Returns a list with the specified number of contiguous elements from the end of an observable sequence. |
| static TakeUntil | Relays elements from the source observable sequence until the provided cancellationToken is cancelled. Completes immediately if the provided cancellationToken is already cancelled upon... |
| static TakeWhile | Returns elements from an observable sequence as long as a specified condition is true. |
| static Throttle | Ignores elements from an observable sequence which are followed by another element within a specified relative time duration. |
| static Throw | Returns an observable sequence that terminates with an exception. |
| static TimeInterval | Records the time interval between consecutive elements in an observable sequence. |
| static Timeout | Applies a timeout policy to the observable sequence based on an absolute time. If the sequence doesn't terminate before the specified absolute due time, a TimeoutException is propagated... |
| static Timer | Returns an observable sequence that produces a single value at the specified absolute due time. |
| static Timestamp | Timestamps each element in an observable sequence using the local system clock. |
| static ToArray | Creates an array from an observable sequence. |
| static ToDictionary | Creates a dictionary from an observable sequence according to a specified key selector function. |
| static ToQueryable | Converts an observable sequence to an enumerable sequence. |
| static ToList | Creates a list from an observable sequence. |
| static ToLookup | Creates a lookup from an observable sequence according to a specified key selector function. |
| static ToObservable | Converts an enumerable sequence to an observable sequence. |
| static Using | Constructs an observable sequence that depends on a resource object, whose lifetime is tied to the resulting observable sequence's lifetime. |
| static Where | Filters the elements of an observable sequence based on a predicate. |
| static While | Repeats the given source as long as the specified condition holds, where the condition is evaluated before each repeated source is subscribed to. |
| static Window | Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on element count information. |
| static WithLatestFrom | Merges two observable sequences into one observable sequence by combining each element from the first source with the latest element from the second source, if any. Starting from Rx.NET 4.0, this... |
| static Zip | Merges the specified observable sequences into one observable sequence by emitting a list with the elements of the observable sequences at corresponding indexes. |
| static ToAsync | Converts the function into an asynchronous action. Each invocation of the resulting asynchronous action causes an invocation of the original synchronous action on the specified scheduler. |
| static FromAsyncPattern | Converts a Begin/End invoke function pair into an asynchronous function. |
| static And | Creates a pattern that matches when both observable sequences have an available element. |
| static Then | Matches when the observable sequence has an available element and projects the element by invoking the selector function. |
| static When | Joins together the results from several patterns. |