public interface CodecEmbedder<E>
EncoderEmbedder
and DecoderEmbedder
for more information.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.
|
ChannelPipeline |
getPipeline()
Returns the
ChannelPipeline that handles the input. |
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.
|
boolean offer(Object input)
boolean finish()
E poll()
null
if and only if there is no output object left in the
product queue.E peek()
poll()
is that it does not remove the
retrieved object from the product queue.null
if and only if there is no output object left in the
product queue.Object[] pollAll()
Collection.toArray()
except that
the product queue is cleared.<T> T[] pollAll(T[] a)
Collection.toArray(Object[])
except that the product queue is cleared.int size()
ChannelPipeline getPipeline()
ChannelPipeline
that handles the input.Copyright © 2008-2013 The Netty Project. All Rights Reserved.