Hands-On Reactive Programming in Spring 5

Support for reactive types conversion

One of the most comprehensive improvements toward supporting the Reactive Streams specification is the introduction of ReactiveAdapter and ReactiveAdapterRegistry. The ReactiveAdapter class gives two fundamental methods for reactive type conversion, as shown in the following code:

class ReactiveAdapter {   ...   <T> Publisher<T> toPublisher(@Nullable Object source) { ... }   // (1)   Object fromPublisher(Publisher<?> publisher) { ... }            // (2)}

In the preceding example, ReactiveAdapter introduces two fundamental methods for the conversion of any type to Publisher<T> (annotated with (1)) and back to Object. For example, in order to provide a conversion for the Maybe reactive type from RxJava 2, we can create ...