
public class DecoderEmbedder<E> extends Object
ChannelBuffer with Base64Decoder and
StringDecoder without setting up the ChannelPipeline and
other mock objects by yourself:
ChannelBufferbase64Data =ChannelBuffers.copiedBuffer("Zm9vYmFy", CharsetUtil.US_ASCII);DecoderEmbedder<String> embedder = newDecoderEmbedder<String>( newBase64Decoder(), newStringDecoder()); embedder.offer(base64Data); String decoded = embedder.poll(); assert decoded.equals("foobar");
EncoderEmbedder| Constructor and Description |
|---|
DecoderEmbedder(ChannelBufferFactory bufferFactory,
ChannelUpstreamHandler... handlers)
Creates a new embedder whose pipeline is composed of the specified
handlers.
|
DecoderEmbedder(ChannelUpstreamHandler... 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. |
ChannelPipeline |
getPipeline()
Returns the
ChannelPipeline that handles the input. |
protected boolean |
isEmpty()
|
boolean |
offer(Object input)
Offers an input object to the pipeline of this embedder.
|
E |
peek()
Reads an encoded or decoded output from the head of the product queue.
|
E |
poll()
Consumes an encoded or decoded output from the product queue.
|
Object[] |
pollAll()
Consumes all encoded or decoded output from the product queue.
|
<T> T[] |
pollAll(T[] a)
Consumes all encoded or decoded output from the product queue.
|
int |
size()
Returns the number of encoded or decoded output in the product queue.
|
public DecoderEmbedder(ChannelUpstreamHandler... handlers)
public DecoderEmbedder(ChannelBufferFactory bufferFactory, ChannelUpstreamHandler... 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<E>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 E poll()
CodecEmbedderpoll in interface CodecEmbedder<E>null if and only if there is no output object left in the
product queue.public final E peek()
CodecEmbedderCodecEmbedder.poll() is that it does not remove the
retrieved object from the product queue.peek in interface CodecEmbedder<E>null if and only if there is no output object left in the
product queue.public final Object[] pollAll()
CodecEmbedderCollection.toArray() except that
the product queue is cleared.pollAll in interface CodecEmbedder<E>public final <T> T[] pollAll(T[] a)
CodecEmbedderCollection.toArray(Object[])
except that the product queue is cleared.pollAll in interface CodecEmbedder<E>public final int size()
CodecEmbeddersize in interface CodecEmbedder<E>public ChannelPipeline getPipeline()
CodecEmbedderChannelPipeline that handles the input.getPipeline in interface CodecEmbedder<E>Copyright © 2008-2014 The Netty Project. All Rights Reserved.