com_baeldung_jetty_httpclient_ReactiveStreamsUnitTest_java
com.baeldung.jetty.httpclient.BlockingSubscriber
public ReactiveResponse block() throws InterruptedException {         return sink.poll(5, TimeUnit.SECONDS);

 -> java.util.concurrent.BlockingQueue.poll(long,java.util.concurrent.TimeUnit): java.lang.Object