Package net.bluemind.core.rest.base

Class GenericStream.AccumulatorStream

java.lang.Object
net.bluemind.core.rest.base.GenericStream.AccumulatorStream
All Implemented Interfaces:
io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>
Enclosing class:
GenericStream<T>
public static class GenericStream.AccumulatorStream extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    AccumulatorStream()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.vertx.core.buffer.Buffer
    buffer()
     
    net.bluemind.core.rest.base.GenericStream.BaseStream<io.vertx.core.buffer.Buffer>
    drainHandler(io.vertx.core.Handler<Void> handler)
     
    io.vertx.core.Future<Void>
    end()
     
    void
    end(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
     
    net.bluemind.core.rest.base.GenericStream.BaseStream<io.vertx.core.buffer.Buffer>
    exceptionHandler(io.vertx.core.Handler<Throwable> handler)
     
    net.bluemind.core.rest.base.GenericStream.BaseStream<io.vertx.core.buffer.Buffer>
    setWriteQueueMaxSize(int maxSize)
     
    io.vertx.core.Future<Void>
    write(io.vertx.core.buffer.Buffer data)
     
    void
    write(io.vertx.core.buffer.Buffer data, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
     
    boolean
    writeQueueFull()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface io.vertx.core.streams.WriteStream

    end, end

  • Constructor Details

    • AccumulatorStream

      public AccumulatorStream()

  • Method Details

    • write

      public io.vertx.core.Future<Void> write(io.vertx.core.buffer.Buffer data)

    • buffer

      public io.vertx.core.buffer.Buffer buffer()

    • exceptionHandler

      public net.bluemind.core.rest.base.GenericStream.BaseStream<io.vertx.core.buffer.Buffer> exceptionHandler(io.vertx.core.Handler<Throwable> handler)
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.StreamBase
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.WriteStream<T>

    • setWriteQueueMaxSize

      public net.bluemind.core.rest.base.GenericStream.BaseStream<io.vertx.core.buffer.Buffer> setWriteQueueMaxSize(int maxSize)
      Specified by:
      setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<T>

    • writeQueueFull

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

    • drainHandler

      public net.bluemind.core.rest.base.GenericStream.BaseStream<io.vertx.core.buffer.Buffer> drainHandler(io.vertx.core.Handler<Void> handler)
      Specified by:
      drainHandler in interface io.vertx.core.streams.WriteStream<T>

    • write

      public void write(io.vertx.core.buffer.Buffer data, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
      Specified by:
      write in interface io.vertx.core.streams.WriteStream<T>

    • end

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

    • end

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