reactive-streams

It would be nice if each operator Javadoc could clearly define the backpressure behaviour.

RxJava does something like this, e.g. http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#flatMap-io.reactivex.functions.Function-

Motivation

I recently ran into an issue where an exception thrown in Micrometer caused my request to break. The actual issue I ran into is not in reactor although reactor was used. However as reactor uses Micrometer as well and e.g. [here|https://github.com/reactor/reactor-netty/blob/main/reactor-netty-core/src/main/java/reactor/netty/channel/AbstractChannelMetricsHandler.java] there also does

Demonstrate how MultiAddressHttpClientBuilder.SingleAddressInitializer can be used to configure underlying clients based on host and port.

An example can be based on one of the http/helloworld examples. Not necessary to repeat all 4 API variants. The goal is only to demonstrate builder features. For example,

Problem or use case

The client is currently only logging errors and warnings. For debugging purposes and during application development, it would be very useful to also have logs detailing the message flow.

Preferred solution or suggestions

TRACE level logging for incoming and outgoing MQTT control packet types, e.g., PUBLISH, SUBSCRIBE, PUBACK, SUBACK.

Context

(Motivated by quarkusio/quarkus#21297)

The existing mutiny-kotlin module provides extensions methods for converting between Uni/Mutli and coroutines; however, it's missing a straightforward way to return a suspending function as a Uni.

[The example in the documentation](https://smallrye.io/smallry

We make sure in the CI configuration to build with jdk8, but it would be safer to specify this in the build (javacOptions/scalacOptions) explicitly.