compose<R> method

Observable<R> compose<R>(Transformer<T, R> transformation)

Prepends the emission of items with transformation.

Implementation

Observable<R> compose<R>(Transformer<T, R> transformation) =>
    transformation(this);