net.bluemind.core.task.service.internal

Class LogStream

java.lang.Object

net.bluemind.core.task.service.internal.LogStream

All Implemented Interfaces:

io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.streams.StreamBase, Stream

public class LogStream
extends java.lang.Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, Stream

Constructor Summary

Constructors

Constructor and Description
LogStream(ISubscriber subscriber)

Method Summary

Modifier and Type	Method and Description
void	end()
LogStream	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
LogStream	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> excHandler)
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long amount)
LogStream	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
LogStream	pause()
LogStream	resume()
void	wakeUp()

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.ReadStream

pipe, pipeTo, pipeTo

Methods inherited from interface net.bluemind.core.api.Stream

charset, fileName, mime

Constructor Detail

LogStream

public LogStream(ISubscriber subscriber)

Method Detail

handler

public LogStream 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

public LogStream pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

resume

public LogStream resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

exceptionHandler

public LogStream exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> excHandler)

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 LogStream endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

wakeUp

public void wakeUp()

end

public void end()

fetch

public io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> fetch(long amount)

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>