net.bluemind.node.server.busmod

Class OutputSplitter

java.lang.Object

net.bluemind.node.server.busmod.OutputSplitter

public class OutputSplitter
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OutputSplitter.Line
static class	OutputSplitter.SplitException

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_FRAME_SIZE Netty max frame length on websockets is 10240, so we default to something smaller

Constructor Summary

Constructors

Constructor and Description
OutputSplitter(io.vertx.core.Handler<OutputSplitter.Line> lineHandler)
OutputSplitter(io.vertx.core.Handler<OutputSplitter.Line> lineHandler, int maxFrameSize)

Method Summary

Modifier and Type	Method and Description
void	end()
OutputSplitter	write(io.netty.buffer.ByteBuf outputChunk)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_FRAME_SIZE

public static final int DEFAULT_MAX_FRAME_SIZE

Netty max frame length on websockets is 10240, so we default to something smaller

See Also:

Constant Field Values

Constructor Detail

OutputSplitter

public OutputSplitter(io.vertx.core.Handler<OutputSplitter.Line> lineHandler)

OutputSplitter

public OutputSplitter(io.vertx.core.Handler<OutputSplitter.Line> lineHandler,
                      int maxFrameSize)

Method Detail

end

public void end()

write

public OutputSplitter write(io.netty.buffer.ByteBuf outputChunk)