public class DecoderEmbedder<E> extends Object
ChannelBuffer
with Base64Decoder
and
StringDecoder
without setting up the ChannelPipeline
and
other mock objects by yourself:
ChannelBuffer
base64Data =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)
CodecEmbedder
true
if and only if there is something to read in the
product queue (see CodecEmbedder.poll()
and CodecEmbedder.peek()
)public boolean finish()
CodecEmbedder
finish
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()
CodecEmbedder
poll
in interface CodecEmbedder<E>
null
if and only if there is no output object left in the
product queue.public final E peek()
CodecEmbedder
CodecEmbedder.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()
CodecEmbedder
Collection.toArray()
except that
the product queue is cleared.pollAll
in interface CodecEmbedder<E>
public final <T> T[] pollAll(T[] a)
CodecEmbedder
Collection.toArray(Object[])
except that the product queue is cleared.pollAll
in interface CodecEmbedder<E>
public final int size()
CodecEmbedder
size
in interface CodecEmbedder<E>
public ChannelPipeline getPipeline()
CodecEmbedder
ChannelPipeline
that handles the input.getPipeline
in interface CodecEmbedder<E>
Copyright © 2008-2014 The Netty Project. All Rights Reserved.