net.bluemind.imap.vertx.parsing

Class ImapChunker

java.lang.Object

net.bluemind.imap.vertx.parsing.ImapChunker

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ImapChunker.ImapChunk
static class	ImapChunker.Type

Constructor Summary

Constructors

Constructor and Description
ImapChunker(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> upstream)

Method Summary

Modifier and Type	Method and Description
ImapChunker	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
ImapChunker	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
ImapChunker	fetch(long amount)
ImapChunker	handler(io.vertx.core.Handler<ImapChunker.ImapChunk> handler)
ImapChunker	pause()
ImapChunker	resume()

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

Constructor Detail

ImapChunker

public ImapChunker(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> upstream)

Method Detail

exceptionHandler

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

Specified by:

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

Specified by:

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

handler

public ImapChunker handler(io.vertx.core.Handler<ImapChunker.ImapChunk> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<ImapChunker.ImapChunk>

pause

public ImapChunker pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<ImapChunker.ImapChunk>

resume

public ImapChunker resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<ImapChunker.ImapChunk>

fetch

public ImapChunker fetch(long amount)

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<ImapChunker.ImapChunk>

endHandler

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

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<ImapChunker.ImapChunk>