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

Caching data with Observable.cache

We can use caching to cache the response in the memory and then, on the next subscription, instead of requesting the remote server again, to use the cached data.

Let's change the code to look like this:

String url = "https://api.github.com/orgs/ReactiveX/repos";
Observable<ObservableHttpResponse> response = request(url);

System.out.println("Not yet subscribed.");
Observable<String> stringResponse = response
.flatMap(resp -> resp.getContent()
.map(bytes -> new String(bytes)))
.retry(5)
.cast(String.class)
.map(String::trim)
.cache();

System.out.println("Subscribe 1:");
System.out.println(stringResponse.toBlocking().first());

System.out.println("Subscribe 2:");
System.out.println(stringResponse.toBlocking().first());

The cache() operator called at the end of the stringResponse chain will cache the response represented by a string for all the following subscribers. So, the output this time will be:

Not yet subscribed.
Subscribe 1:
main :...

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

Caching data with Observable.cache

Learning Reactive Programming With Java 8

By : Nickolay Tzvetinov

Learning Reactive Programming With Java 8

By: Nickolay Tzvetinov

Overview of this book

Caching data with Observable.cache

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