8. Resource Management and Extending RxJava | Learning Reactive Programming With Java 8

Composing multiple operators with the Observable.compose operator

The compose() operator has one parameter of type Transformer. The Transformer interface, like the Operator one, is an empty interface that extends Func1 (this approach hides the type complexities that are involved by using Func1). The difference is that it extends the Func1<Observable<T>, Observable<R>> method, so that it transforms an Observable and not a Subscriber. This means that, instead of operating on each individual item emitted by the source observable, it operates directly on the source.

We can illustrate the use of this operator and the Transformer interface through an example. First, we will create a Transformer implementation:

public class OddFilter<T> implements Transformer<T, T> {
  @Override
  public Observable<T> call(Observable<T> observable) {
    return observable
      .lift(new Indexed<T>(1L))
      .filter(pair -> pair.getLeft() % 2 == 1)
      .map(pair...

Tech Concepts

Programming languages

Tech Tools

Unlimited access to the largest independent learning library in tech of over 8,000 expert-authored tech books and videos.

Innovative learning tools, including AI book assistants, code context explainers, and text-to-speech.

50+ new titles added per month and exclusive early access to books as they are being written.

Learning Reactive Programming With Java 8

By : Nickolay Tzvetinov

Learning Reactive Programming With Java 8

By: Nickolay Tzvetinov

Overview of this book

Composing multiple operators with the Observable.compose operator

Learning Reactive Programming With Java 8

By : Nickolay Tzvetinov

Learning Reactive Programming With Java 8

By: Nickolay Tzvetinov

Overview of this book

Composing multiple operators with the Observable.compose operator

Confirmation

Buy this book with your credits?

Submit Your Feedback

Create a Free Account To Continue Reading

Sign in to activate your 7-day free access