Class GenericJsonObjectWriteStream<T>

java.lang.Object
net.bluemind.core.rest.base.GenericJsonObjectWriteStream<T>
All Implemented Interfaces:
io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

public abstract class GenericJsonObjectWriteStream<T> extends Object implements io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>
  • Constructor Details Link icon

    • GenericJsonObjectWriteStream Link icon

      public GenericJsonObjectWriteStream(Class<T> type)
  • Method Details Link icon

    • drainHandler Link icon

      public GenericJsonObjectWriteStream<T> drainHandler(io.vertx.core.Handler<Void> drainHandler)
      Specified by:
      drainHandler in interface io.vertx.core.streams.WriteStream<T>
    • setWriteQueueMaxSize Link icon

      public GenericJsonObjectWriteStream<T> setWriteQueueMaxSize(int arg0)
      Specified by:
      setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<T>
    • writeQueueFull Link icon

      public boolean writeQueueFull()
      Specified by:
      writeQueueFull in interface io.vertx.core.streams.WriteStream<T>
    • write Link icon

      public io.vertx.core.Future<Void> write(io.vertx.core.buffer.Buffer buffer)
      Specified by:
      write in interface io.vertx.core.streams.WriteStream<T>
    • write Link icon

      public void write(io.vertx.core.buffer.Buffer buffer, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> res)
      Specified by:
      write in interface io.vertx.core.streams.WriteStream<T>
    • end Link icon

      public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> res)
      Specified by:
      end in interface io.vertx.core.streams.WriteStream<T>
    • end Link icon

      public io.vertx.core.Future<Void> end()
      Specified by:
      end in interface io.vertx.core.streams.WriteStream<T>
    • next Link icon

      protected abstract void next(T value) throws Exception
      Throws:
      Exception
    • exceptionHandler Link icon

      public GenericJsonObjectWriteStream<T> exceptionHandler(io.vertx.core.Handler<Throwable> exceptionHandler)
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.StreamBase
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.WriteStream<T>