Package net.bluemind.lib.vertx.utils

Class MmapWriteStream

java.lang.Object
net.bluemind.lib.vertx.utils.MmapWriteStream
All Implemented Interfaces:
io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>
public class MmapWriteStream extends Object implements io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

  • Constructor Summary

    Constructors
    Constructor
    Description
    MmapWriteStream(Path baseDir, long capacity)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.vertx.core.streams.WriteStream<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)
     
    io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>
    exceptionHandler(io.vertx.core.Handler<Throwable> handler)
     
    CompletableFuture<io.netty.buffer.ByteBuf>
    mmap()
     
    io.vertx.core.streams.WriteStream<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

  • Method Details

    • mmap

      public CompletableFuture<io.netty.buffer.ByteBuf> mmap()

    • exceptionHandler

      public io.vertx.core.streams.WriteStream<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<io.vertx.core.buffer.Buffer>

    • write

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

    • 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<io.vertx.core.buffer.Buffer>

    • end

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

    • end

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

    • setWriteQueueMaxSize

      public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> setWriteQueueMaxSize(int maxSize)
      Specified by:
      setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

    • writeQueueFull

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

    • drainHandler

      public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> drainHandler(io.vertx.core.Handler<Void> handler)
      Specified by:
      drainHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>