Hands-On Reactive Programming in Spring 5

Subscribing to Reactive Streams

As we may guess, Flux and Mono provide lambda-based overloads of the subscribe() method, which simplifies the subscription routine a lot:

subscribe();                                                         // (1)
subscribe(Consumer<T> dataConsumer);                                 // (2)
subscribe(Consumer<T> dataConsumer,                                  // (3)
          Consumer<Throwable> errorConsumer);
subscribe(Consumer<T> dataConsumer,                                  // (4)
          Consumer<Throwable> errorConsumer,
          Runnable completeConsumer);
subscribe(Consumer<T> dataConsumer,                                  // (5)
          Consumer<Throwable> errorConsumer,
          Runnable completeConsumer,
          Consumer<Subscription> subscriptionConsumer);subscribe(Subscriber<T> subscriber);                                 // (6)

Let's explore the options we have for creating subscribers. First of all, all overrides of the subscribe method return an instance of ...