net.bluemind.ips.vertx.impl

Class ChunksDrainer

java.lang.Object

net.bluemind.ips.vertx.impl.ChunksDrainer

All Implemented Interfaces:

IParsedChunksDrainer, org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer>

Direct Known Subclasses:

DataHandler, RemoteDataHandler

public abstract class ChunksDrainer
extends java.lang.Object
implements IParsedChunksDrainer, org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer>

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger
protected long	reqId
protected IRecordParser	rp

Constructor Summary

Constructors

Constructor and Description
ChunksDrainer(java.lang.String logPrefix, org.vertx.java.core.net.NetSocket toResume)

Method Summary

Modifier and Type	Method and Description
protected abstract void	flush()
void	handle(org.vertx.java.core.buffer.Buffer b)
protected abstract void	handleRecord(io.netty.buffer.ByteBuf buf, boolean literal, boolean followedByLiteral)
boolean	isBusy()
void	lastChunk()
void	newChunk(ImapChunk qb)
void	setBusy(boolean busy)
void	setBusy(boolean busy, java.lang.String cause)
protected void	setFlushing(boolean f)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected final org.slf4j.Logger logger

rp

protected final IRecordParser rp

reqId

protected long reqId

Constructor Detail

ChunksDrainer

public ChunksDrainer(java.lang.String logPrefix,
                     org.vertx.java.core.net.NetSocket toResume)

Method Detail

isBusy

public final boolean isBusy()

setBusy

public final void setBusy(boolean busy)

setBusy

public final void setBusy(boolean busy,
                          java.lang.String cause)

setFlushing

protected void setFlushing(boolean f)

handle

public final void handle(org.vertx.java.core.buffer.Buffer b)

Specified by:

handle in interface org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer>

handleRecord

protected abstract void handleRecord(io.netty.buffer.ByteBuf buf,
                                     boolean literal,
                                     boolean followedByLiteral)

flush

protected abstract void flush()

newChunk

public final void newChunk(ImapChunk qb)

Specified by:

newChunk in interface IParsedChunksDrainer

lastChunk

public final void lastChunk()

Specified by:

lastChunk in interface IParsedChunksDrainer