Book Image

Learning RxJava - Second Edition

By : Nick Samoylov, Thomas Nield

Book Image

Learning RxJava - Second Edition

By: Nick Samoylov, Thomas Nield

Overview of this book

RxJava is not just a popular library for building asynchronous and event-based applications; it also enables you to create a cleaner and more readable code base. In this book, you’ll cover the core fundamentals of reactive programming and learn how to design and implement reactive libraries and applications. Learning RxJava will help you understand how reactive programming works and guide you in writing your first example in reactive code. You’ll get to grips with the workings of Observable and Subscriber, and see how they are used in different contexts using real-world use cases. The book will also take you through multicasting and caching to help prevent redundant work with multiple Observers. You’ll then learn how to create your own RxJava operators by reusing reactive logic. As you advance, you’ll explore effective tools and libraries to test and debug RxJava code. Finally, you’ll delve into RxAndroid extensions and use Kotlin features to streamline your Android apps. By the end of this book, you'll become proficient in writing reactive code in Java and Kotlin to build concurrent applications, including Android applications.

Preface

Who this book is for

What this book covers

To get the most out of this book

Section 1: Foundations of Reactive Programming in Java

Section 1: Foundations of Reactive Programming in Java

Free Chapter

Thinking Reactively

Thinking Reactively

A brief history of ReactiveX and RxJava

Thinking reactively

Why should I learn RxJava?

A brief exposure to RxJava

RxJava 1.x, 2.x, or 3.0 – which one do I use?

When to use RxJava

Observable and Observer

Observable and Observer

The Observer interface

Cold versus hot observables

Other Observable sources

Single, Completable, and Maybe

Basic Operators

Basic Operators

Conditional operators

Suppressing operators

Transforming operators

Reducing operators

Collection operators

Error recovery operators

Action operators

Utility operators

Section 2: Reactive Operators

Section 2: Reactive Operators

Combining Observables

Combining Observables

Merging factories and operators

Concatenating factories and operators

Ambiguous operators

Zipping operators

Combining the latest operators

Grouping operators

Multicasting, Replaying, and Caching

Multicasting, Replaying, and Caching

Understanding multicasting

Automatic connection

Replaying and caching

Concurrency and Parallelization

Concurrency and Parallelization

Why concurrency is necessary

Concurrency in a nutshell

Introducing RxJava concurrency

Understanding schedulers

Understanding subscribeOn()

Understanding observeOn()

Parallelization

Understanding unsubscribeOn()

Switching, Throttling, Windowing, and Buffering

Switching, Throttling, Windowing, and Buffering

Grouping keystrokes

Flowable and Backpressure

Flowable and Backpressure

Understanding backpressure

Understanding Flowable and Subscriber

Creating Flowable

Using onBackpressureXXX() operators

Using Flowable.generate()

Transformers and Custom Operators

Transformers and Custom Operators

Composing new operators from existing ones using compose() and transformers

Using the to() operator for fluent conversion

Creating new operators from scratch using lift()

Creating a new operator for Single, Maybe, or Completable

Using RxJava2-Extras and RxJava2Extensions

Section 3: Integration of RxJava applications

Section 3: Integration of RxJava applications

Testing and Debugging

Testing and Debugging

Configuring JUnit

Blocking subscribers

Blocking operators

Using TestObserver and TestSubscriber

Manipulating time with TestScheduler

Debugging RxJava code

RxJava on Android

RxJava on Android

Creating an Android project

Using RxJava and RxAndroid

Using RxJava for Kotlin

Using RxJava for Kotlin

Configuring Kotlin

Extension operators

Dealing with SAM ambiguity

Using let() and apply()

Tuple and data classes

The future of ReactiveX and Kotlin

Other Books You May Enjoy

Other Books You May Enjoy

Leave a review - let other readers know what you think

Appendix A: Introducing Lambda Expressions

Appendix A: Introducing Lambda Expressions

Introducing lambda expressions

Appendix B: Functional Types

Appendix B: Functional Types

Functional types

Appendix C: Mixing Object-Oriented and Reactive Programming

Appendix C: Mixing Object-Oriented and Reactive Programming

Mixing object-oriented and reactive programming

Appendix D: Materializing and Dematerializing

Appendix D: Materializing and Dematerializing

Materializing and dematerializing

Appendix E: Understanding Schedulers

Appendix E: Understanding Schedulers

Understanding Schedulers

Customer Reviews

5 star

0

4 star

0

3 star

0

2 star

0

1 star

0

Other Books You May Enjoy

If you enjoyed this book, you may be interested in these other books by Packt:

Hands-On Enterprise Java Microservices with Eclipse MicroProfile
Cesar Saavedra, Heiko W. Rupp, Et al

ISBN: 978-1-83864-310-2

Understand why microservices are important in the digital economy
Analyze how MicroProfile addresses the need for enterprise Java microservices
Test and secure your applications with Eclipse MicroProfile
Get to grips with various MicroProfile capabilities such as OpenAPI and Typesafe REST Client
Explore reactive programming with MicroProfile Stream and Messaging candidate APIs
Discover and implement coding best practices using MicroProfile

Hands-On Cloud-Native Applications with Java and Quarkus
Francesco Marchioni

ISBN: 978-1-83882-147-0

Build a native application using Quarkus and GraalVM
Secure your applications using Elytron and the MicroProfile...