net.bluemind.imap.vertx.parsing

Class ImapChunkProcessor

java.lang.Object

net.bluemind.imap.vertx.parsing.ImapChunkProcessor

All Implemented Interfaces:

io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

public class ImapChunkProcessor
extends java.lang.Object
implements io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

Constructor Summary

Constructors

Constructor and Description
ImapChunkProcessor()

Method Summary

Modifier and Type	Method and Description
ImapChunkProcessor	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)
ImapChunkProcessor	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
void	setDelegate(IProcessorDelegate del)
ImapChunkProcessor	setWriteQueueMaxSize(int maxSize)
io.vertx.core.Future<java.lang.Void>	write(ImapChunker.ImapChunk data)
void	write(ImapChunker.ImapChunk 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

Constructor Detail

ImapChunkProcessor

public ImapChunkProcessor()

Method Detail

setDelegate

public void setDelegate(IProcessorDelegate del)

exceptionHandler

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

Specified by:

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

Specified by:

exceptionHandler in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

write

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

Specified by:

write in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

write

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

Specified by:

write in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

end

public io.vertx.core.Future<java.lang.Void> end()

Specified by:

end in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

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<ImapChunker.ImapChunk>

setWriteQueueMaxSize

public ImapChunkProcessor setWriteQueueMaxSize(int maxSize)

Specified by:

setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

writeQueueFull

public boolean writeQueueFull()

Specified by:

writeQueueFull in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>

drainHandler

public ImapChunkProcessor drainHandler(io.vertx.core.Handler<java.lang.Void> handler)

Specified by:

drainHandler in interface io.vertx.core.streams.WriteStream<ImapChunker.ImapChunk>