7. Testing Your RxJava Application | Learning Reactive Programming With Java 8

The BlockingObservable class

Every Observable instance can be turned into a BlockingObservable instance with the toBlocking() method. The BlockingObservable instance has multiple methods that block the current thread, while everything is emitted by the source Observable instance until an OnCompleted or OnError notification is sent. If there is an OnError notification, an exception will be thrown (RuntimeException exceptions are thrown directly and checked exceptions are wrapped inside the RuntimeException instances).

The toBlocking() method doesn't block by itself, but the methods of the BlockingObservable instance it returns may block. Let's look at some of those methods:

We can iterate over all the items in the BlockingObservable instance, using the forEach() method. Here is an example of using this:

Observable
  .interval(100L, TimeUnit.MILLISECONDS)
  .take(5)
  .toBlocking()
  .forEach(System.out::println);
System.out.println("END");

This is also an example of how to make asynchronous code...

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 BlockingObservable class

Learning Reactive Programming With Java 8

By : Nickolay Tzvetinov

Learning Reactive Programming With Java 8

By: Nickolay Tzvetinov

Overview of this book

The BlockingObservable class

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