Collects items from the original observable into buffers until the notifier emits. If no items have been buffered since the last time the notifier emitted, nothing will be emitted. Closing the emitter will emit the remaining buffer.

Collects items from the original observable into buffers of size count.

Combines items from the original observable with the other observables. See combineLatest.

Converts a higher-order Observable into a first-order Observable by concatenating the inner Observables in order.

Returns a Transform where items are only emitted if ms milliseconds pass without new a new emit by the source observable. If a new value is emitted, the “cooldown” is restarted and the old value is discarded.

Returns a Transform where all subsequent repetitions of the same item are filtered out.

Returns a Transform that emits the items specified as arguments after te source observable ends.

Converts a higher-order Observable into a first-order Observable by dropping inner Observables while the previous inner Observable has not yet completed.

Returns a Transform that emits all items for which f returns true.

Returns a Transform that emits the first item in an observable. The source observable will be drained after.

Calls a function for each item emitted by an observable without waiting for the function to return to forward the item. Exceptions thrown by the function will be caught and ignored.

Returns a Transform that emits the last item in an observable.

Returns a Transform with the results of applying the given function to each emitted item of the original observable.

Merges another observable by emitting all items from both the original observable and the other observable. Items are emitted in the order they appear.

Emits the most recently emitted value from the Observable whenever the notifier emits. If no new value has been emitted from the source observable since the last time the notifier emitted, nothing will be emitted.

Reduces the original observable with f, emitting every intermediate result not including the initial value.

Returns a Transform that applies f to the observable.

Converts a higher-order Observable into a first-order Observable producing values only from the most recent observable sequence.

Converts each emitted item to an observable, producing values only from the most recent observable in the sequence.

Returns a Transform that emits the first n items from the original observable.

Returns a Transform that emits items from the original observable until f returns false.

Alias for forEach.

Branches out the source observable as nested observables whenever notifier emits.

Zips items from the original observable with the other observable. See zip.