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 jetty-project/jetty-reactive-httpclient#22 so that the Jetty reactive client can abort the request in case of a cancel signal.
The connector uses
Mono.from(Publisher)to obtain Jetty'sReactiveResponse. However it also cancels after the first item and is meant for use with aPublisherthat can produce a sequence. We need to useMono.fromDirectinstead which does not cancel the upstream since in this case we only expect one item.This will help with jetty-project/jetty-reactive-httpclient#22 so that the Jetty reactive client can abort the request in case of a cancel signal.