Hi,

I am writing a websocket client with APIs ReactiveResponseConsumer and
ReactiveEntityProducer. Once the websocket server completes the handshake
by upgrading connection and returning 101. We do get Http status code and
headers after the handshake completes. But not Publisher<ByteBuffer>.

So we get httpStatus and headers from
https://github.com/apache/httpcomponents-core/blob/master/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java#L210
But it returns if the status code is less 200.
https://github.com/apache/httpcomponents-core/blob/master/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java#L229
We want it to consume entity details so we get Publisher<ByteBuffer>
https://github.com/apache/httpcomponents-core/blob/master/httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/ClientHttp1StreamHandler.java#L249

Could you help figuring this out?

Thanks,
Sneha

Reply via email to