The Observable.create method

Let's look at the signature of the method first:

public final static <T> Observable<T> create(OnSubscribe<T>)

It takes a parameter of type OnSubscribe. This interface extends the Action1<Subscriber<? super T>> interface; in other words, this type has only one method, taking one argument of type Subscriber<T> and returning nothing. This function will be called every time the Observable.subscribe() method is invoked. Its argument, an instance of the Subscriber class, is in fact the observer, subscribing to the Observable instance (here, the Subscriber class and Observer interface have the same role). We'll be talking about them later in this chapter). We can invoke the onNext(), onError(), and onCompleted() methods on it, implementing our own custom behavior.

It's easier to comprehend this with an example. Let's implement a simple version of the Observable.from(Iterabale<T>) method:

<T> Observable...

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

The Observable.create method

Learning Reactive Programming With Java 8

By : Nickolay Tzvetinov

Learning Reactive Programming With Java 8

By: Nickolay Tzvetinov

Overview of this book

The Observable.create method

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