Package org.jboss.resteasy.reactive.server.vertx

Class VertxInputStream.VertxBlockingInput

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

  • Field Details

    • request

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

    • inputOverflow

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

    • endOfWrite

      protected boolean endOfWrite

    • readException

      protected IOException readException

  • Constructor Details

    • VertxBlockingInput

      public VertxBlockingInput(io.vertx.core.http.HttpServerRequest request, 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()