Class VertxStream.LocalPathStream

java.lang.Object
net.bluemind.core.rest.vertx.VertxStream.LocalPathStream
All Implemented Interfaces:
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.streams.StreamBase, Stream
Enclosing class:
VertxStream

public static class VertxStream.LocalPathStream extends Object implements Stream, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>
  • Constructor Details

    • LocalPathStream

      public LocalPathStream(Path p)
  • Method Details

    • path

      public Path path()
    • handler

      public VertxStream.LocalPathStream handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
      Specified by:
      handler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>
    • pause

      Specified by:
      pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>
    • resume

      public VertxStream.LocalPathStream resume()
      Specified by:
      resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>
    • exceptionHandler

      public VertxStream.LocalPathStream exceptionHandler(io.vertx.core.Handler<Throwable> handler)
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>
      Specified by:
      exceptionHandler in interface io.vertx.core.streams.StreamBase
    • endHandler

      public VertxStream.LocalPathStream endHandler(io.vertx.core.Handler<Void> endHandler)
      Specified by:
      endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>
    • fetch

      public VertxStream.LocalPathStream fetch(long amount)
      Specified by:
      fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>