chunkify( ) — returns an iterable that periodically returns a list of items emitted by the source Observable since the last list (⁇)

collect( ) — collects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure

combineLatest( ) — when an item is emitted by either of two Observables, combine the latest item emitted by each Observable via a specified function and emit items based on the results of this function

debounce( ) — only emit an item from the source Observable after a particular timespan has passed without the Observable emitting any other items

decode( ) (StringObservable) — convert a stream of multibyte characters into an Observable that emits byte arrays that respect character boundaries

defaultIfEmpty( ) — emit items from the source Observable, or emit a default item if the source Observable completes after emitting no items

defer( ) — do not create the Observable until a Subscriber subscribes; create a fresh Observable on each subscription

deferFuture( ) — convert a Future that returns an Observable into an Observable, but do not attempt to get the Observable that the Future returns until a Subscriber subscribes (rxjava-async)

deferCancellableFuture( ) — convert a Future that returns an Observable into an Observable in a way that monitors the subscription status of the Observable to determine whether to halt work on the Future, but do not attempt to get the returned Observable until a Subscriber subscribes (⁇)(rxjava-async)

delay( ) — shift the emissions from an Observable forward in time by a specified amount

dematerialize( ) — convert a materialized Observable back into its non-materialized form

forEach( ) (BlockingObservable) — invoke a function on each item emitted by the Observable; block until the Observable completes

forEachFuture( ) (Async) — pass Subscriber methods to an Observable but also have it behave like a Future that blocks until it completes (rxjava-async)

forEachFuture( ) (BlockingObservable)— create a futureTask that will invoke a specified function on each item emitted by an Observable (⁇)

forIterable( ) — apply a function to the elements of an Iterable to create Observables which are then concatenated (⁇)

from( ) — convert an Iterable, a Future, or an Array into an Observable

from( ) (StringObservable) — convert a stream of characters or a Reader into an Observable that emits byte arrays or Strings

fromAction( ) — convert an Action into an Observable that invokes the action and emits its result when a Subscriber subscribes (rxjava-async)

fromCallable( ) — convert a Callable into an Observable that invokes the callable and emits its result or exception when a Subscriber subscribes (rxjava-async)

fromCancellableFuture( ) — convert a Future into an Observable in a way that monitors the subscription status of the Observable to determine whether to halt work on the Future, but do not attempt to get the Future's value until a Subscriber subscribes (⁇)(rxjava-async)

split( ) (StringObservable) — converts an Observable of Strings into an Observable of Strings that treats the source sequence as a stream and splits it on a specified regex boundary

start( ) — create an Observable that emits the return value of a function (rxjava-async)

startCancellableFuture( ) — convert a function that returns Future into an Observable that emits that Future's return value in a way that monitors the subscription status of the Observable to determine whether to halt work on the Future (⁇)(rxjava-async)

startFuture( ) — convert a function that returns Future into an Observable that emits that Future's return value (rxjava-async)

startWith( ) — emit a specified sequence of items before beginning to emit the items from the Observable

stringConcat( ) (StringObservable) — converts an Observable that emits a sequence of strings into an Observable that emits a single string that concatenates them all

subscribeOn( ) — specify which Scheduler an Observable should use when its subscription is invoked

sumDouble( ) — adds the Doubles emitted by an Observable and emits this sum (rxjava-math)

sumFloat( ) — adds the Floats emitted by an Observable and emits this sum (rxjava-math)

sumInteger( ) — adds the Integers emitted by an Observable and emits this sum (rxjava-math)

sumLong( ) — adds the Longs emitted by an Observable and emits this sum (rxjava-math)