Integrating RxJava 2.0
From our conclusion that Spring 5 understands the full language of reactive programming, this recipe will show us that this Spring version does not only supports its built-in Reactor Core extension but can also extend its translation to RxJava 2.x.
Getting started
Add the following service methods and @Controller
request handlers to ch08
which will also highlight RxJava 2.x stream transactions.
How to do it...
Aside from Reactor Core, Spring 5 can work with other reactive libraries, just like the popular RxJava 2.0. Follow these steps to guide on how to integrate RxJava 2.0 with Spring 5:
- Before we start, add the Maven dependencies of RxJava 2.x to
pom.xml
. This set of libraries has been used in the previous chapter.
- Open the
DepartmentService
class and add the following template methods that will soon be implemented as non-blocking transactions:
public interface DepartmentService { // refer to sources public Observable<Department> getDeptsRx(); public Single...