
public class EncoderEmbedder<T> extends Object
String into a Base64-encoded ChannelBuffer with
Base64Encoder and StringEncoder without setting up the
ChannelPipeline and other mock objects by yourself:
String data = "foobar";
EncoderEmbedder<ChannelBuffer> embedder = new EncoderEmbedder<ChannelBuffer>(
new Base64Encoder(), new StringEncoder());
embedded.offer(data);
ChannelBuffer encoded = embedded.poll();
assert encoded.toString("ASCII").equals("Zm9vYmFy");
DecoderEmbedder| Constructor and Description |
|---|
EncoderEmbedder(ChannelBufferFactory bufferFactory,
ChannelDownstreamHandler... handlers)
Creates a new embedder whose pipeline is composed of the specified
handlers.
|
EncoderEmbedder(ChannelDownstreamHandler... handlers)
Creates a new embedder whose pipeline is composed of the specified
handlers.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
finish()
Signals the pipeline that the encoding or decoding has been finished and
no more data will be offered.
|
protected Channel |
getChannel()
Returns the virtual
Channel which will be used as a mock
during encoding and decoding. |
protected boolean |
isEmpty()
|
boolean |
offer(Object input)
Offers an input object to the pipeline of this embedder.
|
T |
peek()
Reads an encoded or decoded output from the head of the product queue.
|
T |
poll()
Consumes an encoded or decoded output from the product queue.
|
public EncoderEmbedder(ChannelDownstreamHandler... handlers)
public EncoderEmbedder(ChannelBufferFactory bufferFactory, ChannelDownstreamHandler... handlers)
bufferFactory - the ChannelBufferFactory to be used when
creating a new buffer.public boolean offer(Object input)
CodecEmbeddertrue if and only if there is something to read in the
product queue (see CodecEmbedder.poll() and CodecEmbedder.peek())public boolean finish()
CodecEmbedderfinish in interface CodecEmbedder<T>true if and only if there is something to read in the
product queue (see CodecEmbedder.poll() and CodecEmbedder.peek())protected final Channel getChannel()
Channel which will be used as a mock
during encoding and decoding.protected final boolean isEmpty()
public final T poll()
CodecEmbedderpoll in interface CodecEmbedder<T>null if and only if there is no output object left in the
product queue.public final T peek()
CodecEmbedderCodecEmbedder.poll() is that it does not remove the
retrieved object from the product queue.peek in interface CodecEmbedder<T>null if and only if there is no output object left in the
product queue.Copyright © 2008-2013 JBoss, by Red Hat. All Rights Reserved.