Bus that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.

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.

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 (constructor).

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

A variant of conbine-latest* that accepts an array or sequential

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

Concatenates all of the specified observable sequences, as long as the previous observable sequence terminated successfully.

Like reduce but accepts a function that returns a stream. Will use as value for the next step in the reduce the last valued emited by the stream in the function.

Connect the connectable observable.

Creates an observable sequence from a specified subscribe method implementation.

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.

Check if the provided object is disposable (jvm) or subscription (js).

Dispose resources acquired by the subscription.

Returns an observable sequence that is already in end state.

Ends the given bus stream.

Same as throw

Pushes the given error to the bus stream.

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.

Return an observable that only has the first value of the provided observable. You can optionally pass a predicate and default value.

Runs all observable sequences in parallel and collect their last elements.

Just like clojure collections flatten but for rx streams. Given a stream off collections will emit every value separately

Creates an observable from js arrays, clojurescript collections, and promise instance.

Creates an Observable by attaching an event listener to an event target

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.

Returns an observable sequence that produces a value after each period.

Return an observable that only has the last value of the provided observable. You can optionally pass a predicate and default value.

Apply a function to each element of an observable sequence.

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.

Merges all the observable sequences and Promises into a single observable sequence.

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.

Return true if ob is a instance of Rx.Observable.

Converts arguments to an observable sequence

Create a connectable (hot) observable from other observable.

Pushes the given value to the bus stream.

Create an observable that surfaces any of the given sequences, whichever reacted first.

Generates an observable sequence that repeats the given element.

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

Get the scheduler instance by type. The posible types are: :asap, :async, :queue. Old :trampoline type is renamed as :queue and is deprecated.

Check if the provided value is Scheduler instance.

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.

Subscribes an observer to the observable sequence.

Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.

Check if the provided value is Subject instance.

A specialized version of subscribe with inverted arguments.

Subscribes an observer to the observable sequence.

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.

Returns an exceptionally terminated observable with provided cause.

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

Returns an observable sequence that produces a value after ms has elapsed and then after each period.

Materialize the observable sequence into an atom.

Coerce a object to an observable instance.

Transform the observable sequence using transducers.

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.

Merges the specified observable sequences or Promises (cljs) into one observable sequence.