net.bluemind.imap.vertx.stream

Class WriteToRead<T>

java.lang.Object

net.bluemind.imap.vertx.stream.WriteToRead<T>

All Implemented Interfaces:

io.vertx.core.streams.ReadStream<T>, io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<T>

public class WriteToRead<T>
extends java.lang.Object
implements io.vertx.core.streams.WriteStream<T>, io.vertx.core.streams.ReadStream<T>

Constructor Summary

Constructors

Constructor and Description
WriteToRead(io.vertx.core.Vertx vertx)

Method Summary

Modifier and Type	Method and Description
WriteToRead<T>	drainHandler(io.vertx.core.Handler<java.lang.Void> handler)
io.vertx.core.Future<java.lang.Void>	end()
void	end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
WriteToRead<T>	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
WriteToRead<T>	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
WriteToRead<T>	fetch(long amount)
WriteToRead<T>	handler(io.vertx.core.Handler<T> handler)
WriteToRead<T>	pause()
WriteToRead<T>	resume()
WriteToRead<T>	setWriteQueueMaxSize(int maxSize)
io.vertx.core.Future<java.lang.Void>	write(T data)
void	write(T data, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.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

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

pipe, pipeTo, pipeTo

Constructor Detail

WriteToRead

public WriteToRead(io.vertx.core.Vertx vertx)

Method Detail

exceptionHandler

public WriteToRead<T> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)

Specified by:

exceptionHandler in interface io.vertx.core.streams.ReadStream<T>

Specified by:

exceptionHandler in interface io.vertx.core.streams.StreamBase

Specified by:

exceptionHandler in interface io.vertx.core.streams.WriteStream<T>

write

public io.vertx.core.Future<java.lang.Void> write(T data)

Specified by:

write in interface io.vertx.core.streams.WriteStream<T>

write

public void write(T data,
                  io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

write in interface io.vertx.core.streams.WriteStream<T>

end

public io.vertx.core.Future<java.lang.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<java.lang.Void>> handler)

Specified by:

end in interface io.vertx.core.streams.WriteStream<T>

setWriteQueueMaxSize

public WriteToRead<T> 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 WriteToRead<T> drainHandler(io.vertx.core.Handler<java.lang.Void> handler)

Specified by:

drainHandler in interface io.vertx.core.streams.WriteStream<T>

handler

public WriteToRead<T> handler(io.vertx.core.Handler<T> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<T>

pause

public WriteToRead<T> pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<T>

resume

public WriteToRead<T> resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<T>

fetch

public WriteToRead<T> fetch(long amount)

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<T>

endHandler

public WriteToRead<T> endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<T>