public class DecoderEmbedder<E>
extends java.lang.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
构造器和说明 |
---|
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.
|
限定符和类型 | 方法和说明 |
---|---|
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(java.lang.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.
|
java.lang.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(java.lang.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
在接口中 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
在接口中 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
在接口中 CodecEmbedder<E>
null
if and only if there is no output object left in the
product queue.public final java.lang.Object[] pollAll()
CodecEmbedder
Collection.toArray()
except that
the product queue is cleared.pollAll
在接口中 CodecEmbedder<E>
public final <T> T[] pollAll(T[] a)
CodecEmbedder
Collection.toArray(Object[])
except that the product queue is cleared.pollAll
在接口中 CodecEmbedder<E>
public final int size()
CodecEmbedder
size
在接口中 CodecEmbedder<E>
public ChannelPipeline getPipeline()
CodecEmbedder
ChannelPipeline
that handles the input.getPipeline
在接口中 CodecEmbedder<E>