• chunkify( )
• returns an iterable that periodically returns a list of items emitted by the source Observable since the last list
• fromFuture( )
• convert a Future into an Observable, but do not attempt to get the Future's value until a Subscriber subscribes
• forEachFuture( )
• 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
• fromCancellableFuture( ), startCancellableFuture( ), and deferCancellableFuture( )
• versions of Future-to-Observable converters that monitor the subscription status of the Observable to determine whether to halt work on the Future
• generate( ) and generateAbsoluteTime( )
• create an Observable that emits a sequence of items as generated by a function of your choosing
• see also:
• groupByUntil( )
• a variant of the groupBy operator that closes any open GroupedObservable upon a signal from another Observable
• multicast( )
• represents an Observable as a Connectable Observable
• see also:
• onErrorFlatMap( )
• instructs an Observable to emit a sequence of items whenever it encounters an error
• parallel( )
• split the work done on the emissions from an Observable into multiple Observables each operating on its own parallel thread
• see also:
• parallelMerge( )
• combine multiple Observables into a smaller number of Observables, to facilitate parallelism
• pivot( )
• combine multiple sets of grouped observables so that they are arranged primarily by group rather than by set
• publishLast( )
• represent an Observable as a Connectable Observable that emits only the last item emitted by the source Observable
• see also: