Package org.jboss.resteasy.reactive.client.handlers

Class VertxClientInputStream.VertxBlockingInput

java.lang.Object
org.jboss.resteasy.reactive.client.handlers.VertxClientInputStream.VertxBlockingInput
All Implemented Interfaces:
io.vertx.core.Handler<io.vertx.core.buffer.Buffer>
Enclosing class:
VertxClientInputStream
public static class VertxClientInputStream.VertxBlockingInput extends Object implements io.vertx.core.Handler<io.vertx.core.buffer.Buffer>

  • Field Details

    • request

      protected final io.vertx.core.http.HttpClientResponse request

    • input1

      protected io.vertx.core.buffer.Buffer input1

    • inputOverflow

      protected Deque<io.vertx.core.buffer.Buffer> inputOverflow

    • waiting

      protected boolean waiting

    • eof

      protected boolean eof

    • readException

      protected Throwable readException

  • Constructor Details

    • VertxBlockingInput

      public VertxBlockingInput(io.vertx.core.http.HttpClientResponse response, long timeout)

  • Method Details

    • readBlocking

      protected io.netty.buffer.ByteBuf readBlocking() throws IOException
      Throws:
      IOException

    • handle

      public void handle(io.vertx.core.buffer.Buffer event)
      Specified by:
      handle in interface io.vertx.core.Handler<io.vertx.core.buffer.Buffer>

    • readBytesAvailable

      public int readBytesAvailable()

    • discard

      public void discard()