public class DecoderEmbedder<E> extends AbstractCodecEmbedder<E>
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");
EncoderEmbedderproductQueue| 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 |
offer(java.lang.Object input)
Offers an input object to the pipeline of this embedder.
|
finish, getChannel, getPipeline, isEmpty, peek, poll, pollAll, pollAll, sizepublic DecoderEmbedder(ChannelUpstreamHandler... handlers)
public DecoderEmbedder(ChannelBufferFactory bufferFactory, ChannelUpstreamHandler... handlers)
bufferFactory - the ChannelBufferFactory to be used when
creating a new buffer.public boolean offer(java.lang.Object input)
CodecEmbeddertrue if and only if there is something to read in the
product queue (see CodecEmbedder.poll() and CodecEmbedder.peek())