Beicon Api Documentation

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.

Dispose resources acquired by the subscription.

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.

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

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.

Returns an observable sequence that contains only distinct contiguous elements.

Returns an observable sequence that contains only d istinct elements. Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.

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

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

An idiomatic alias for tap.

Returns an observable sequence that is already in end state.

Mark a value as a final value of the stream.

Ends the given bus stream.

Pushes the given error to the bus stream.

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

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

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.

Alias to fjoin.

Generates an observable sequence from collection.

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

Creates an observable from a promise.

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

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

Backpressure aware subscriber abstraction.

Returns an observable sequence that contains a single element.

Print all values passed through the given observable sequence.

Apply a function to each element of an observable sequence.

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.

An idiomatic alias for flat-map.

Alias to ‘empty’.

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

Check if the provided value is Observer instance.

Converts arguments to an observable sequence.

A semantic alias for on-end.

Subscribes a function to invoke upon graceful termination of the observable sequence.

Subscribes a function to invoke upon exceptional termination of the observable sequence.

A semantic alias for on-value.

Subscribes a function to invoke for each element in the observable sequence.

An alias to just.

Print all values passed through the given observable sequence using pr-str.

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.

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.

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

Check if the provided value is Subject instance.

Subscribes an observer to the observable sequence.

Subscribes an observer or subscriber 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 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.

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 into one observable sequence.