The connector uses Mono.from(Publisher)
to obtain Jetty's ReactiveResponse
. However it also cancels after the first item and is meant for use with a Publisher
that can produce a sequence. We need to use Mono.fromDirect
instead which does not cancel the upstream since in this case we only expect one item.
This will help with https://github.com/jetty-project/jetty-reactive-httpclient/issues/22 so that the Jetty reactive client can abort the request in case of a cancel signal.