Projects each element of an observable sequence into zero or more buffers which are produced based on element count information.

Buffers the source Observable values for a specific time period. (operator only)

Buffers the source Observable values until notifier emits.

Continues an observable sequence that is terminated by an exception with the next observable sequence.

Combines multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables (operator).

Emits an item from the source Observable after a particular timespan has passed without the Observable omitting any other items.

Time shifts the observable sequence by dueTime. The relative time intervals between the values are preserved.

Time shifts at least ms milisseconds.

Time shifts the observable sequence based on a subscription delay and a delay selector function for each element.

Returns an observable sequence that contains only distinct elements.

Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.

Returns an observable sequence that contains only distinct contiguous elements.

Recursively projects each source value to an Observable which is merged in the output Observable.

Filters the elements of an observable sequence based on a predicate.

Returns an Observable that mirrors the source Observable, but will call a specified function when the source terminates on complete or error.

Emits a given value if the source Observable completes without emitting any next value, otherwise mirrors the source Observable.

Ignores all elements in an observable sequence leaving only the termination messages.

Same as map but also projects an index.

Projects each element of an observable sequence to an observable sequence and concatenates the resulting observable sequences or Promises or array/iterable into one observable sequence.

Indexed variant of mapcat

Merges an observable sequence of observable sequences into an observable sequence.

Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences or Promises or array/iterable into one observable sequence.

In other languages is called: flatMap or mergeMap.

Applies an accumulator function over the source Observable where the accumulator function itself returns an Observable, then each intermediate Observable returned is merged into the output Observable.

Applies an accumulator function over an observable sequence, returning the result of the aggregation as a single element in the result sequence.

Given an optional number of retries and an observable, repeats the source observable the specified number of times or until it terminates. If no number of retries is given, it will be retried indefinitely.

Samples the observable sequence at each interval.

Samples the observable sequence at each interval.

Applies an accumulator function over an observable sequence and returns each intermediate result. Same as reduce but with intermediate results

Returns an observable sequence that shares a single subscription to the underlying sequence.

Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.

Skip a specified number of values before the completion of an observable.

Returns the values from the source observable sequence only after the other observable sequence produces a value.

Bypasses elements in an observable sequence as long as a specified condition is true and then returns the remaining elements.

Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.

Returns the values from the source observable sequence until the other observable sequence or Promise produces a value.

Returns elements from an observable sequence as long as a specified predicate returns true.

Invokes an action for each element in the observable sequence.

Returns an observable sequence that emits only the first item emitted by the source Observable during sequential time windows of a specified duration.

(operator only)

Returns the source observable sequence or the other observable sequence if dueTime elapses.

Merges the specified observable sequences into one observable sequence by using the selector function only when the source observable sequence (the instance) produces an element.

(operator)