net.bluemind.eas.backend.bm.mail.loader

Class BodyAccumulator

java.lang.Object

net.bluemind.eas.backend.bm.mail.loader.BodyAccumulator

public class BodyAccumulator
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
BodyAccumulator(BodyOptions options)

Method Summary

Modifier and Type	Method and Description
AirSyncBaseResponse.Body	body()
void	consumeBodyPart(MessageBody.Part bodyPart, Stream stream)
void	consumeMime(Stream stream)
BodyType	getBodyType()
AirSyncBaseResponse.NativeBodyType	nativeBodyType()
io.netty.buffer.ByteBuf	toByteBuf(Stream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

BodyAccumulator

public BodyAccumulator(BodyOptions options)

Method Detail

toByteBuf

public io.netty.buffer.ByteBuf toByteBuf(Stream stream)
                                  throws java.lang.InterruptedException,
                                         java.util.concurrent.ExecutionException,
                                         java.util.concurrent.TimeoutException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

consumeMime

public void consumeMime(Stream stream)

consumeBodyPart

public void consumeBodyPart(MessageBody.Part bodyPart,
                            Stream stream)

body

public AirSyncBaseResponse.Body body()

nativeBodyType

public AirSyncBaseResponse.NativeBodyType nativeBodyType()

getBodyType

public BodyType getBodyType()