Uses of Interface
io.netty.buffer.ByteBufAllocator
-
Packages that use ByteBufAllocator Package Description io.netty.buffer Abstraction of a byte buffer - the fundamental data structure to represent a low-level binary and text message.io.netty.channel The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.io.netty.channel.epoll Optimized transport for linux which uses EPOLL Edge-Triggered Mode for maximal performance.io.netty.channel.kqueue BSD specific transport.io.netty.channel.rxtx A serial and parallel port communication transport based on RXTX.io.netty.channel.sctp Abstract SCTP socket interfaces which extend the core channel API.io.netty.channel.socket Abstract TCP and UDP socket interfaces which extend the core channel API.io.netty.channel.socket.oio Old blocking I/O based socket channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.udt UDT Transport.io.netty.channel.unix Unix specific transport.io.netty.channel.uring io_uring is a high I/O performance scalable interface for fully asynchronous Linux syscalls.io.netty.handler.codec Extensible decoder and its common implementations which deal with the packet fragmentation and reassembly issue found in a stream-based transport such as TCP/IP.io.netty.handler.codec.base64 io.netty.handler.codec.http Encoder, decoder and their related message types for HTTP.io.netty.handler.codec.http.multipart HTTP multipart support.io.netty.handler.codec.http.websocketx Encoder, decoder, handshakers and their related message types for Web Socket data frames.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.codec.spdy Encoder, decoder, session handler and their related message types for the SPDY protocol.io.netty.handler.ssl SSL · TLS implementation based onSSLEngine
io.netty.handler.stream Writes very large data stream asynchronously neither spending a lot of memory nor gettingOutOfMemoryError
. -
-
Uses of ByteBufAllocator in io.netty.buffer
Classes in io.netty.buffer that implement ByteBufAllocator Modifier and Type Class Description class
AbstractByteBufAllocator
SkeletalByteBufAllocator
implementation to extend.class
AdaptiveByteBufAllocator
An auto-tuning poolingByteBufAllocator
, that follows an anti-generational hypothesis.class
PooledByteBufAllocator
class
UnpooledByteBufAllocator
SimplisticByteBufAllocator
implementation that does not pool anything.Fields in io.netty.buffer declared as ByteBufAllocator Modifier and Type Field Description static ByteBufAllocator
ByteBufAllocator. DEFAULT
Methods in io.netty.buffer that return ByteBufAllocator Modifier and Type Method Description abstract ByteBufAllocator
ByteBuf. alloc()
Returns theByteBufAllocator
which created this buffer.ByteBufAllocator
CompositeByteBuf. alloc()
ByteBufAllocator
DuplicatedByteBuf. alloc()
Deprecated.ByteBufAllocator
EmptyByteBuf. alloc()
ByteBufAllocator
ReadOnlyByteBuf. alloc()
Deprecated.ByteBufAllocator
SwappedByteBuf. alloc()
Deprecated.ByteBufAllocator
UnpooledDirectByteBuf. alloc()
ByteBufAllocator
UnpooledHeapByteBuf. alloc()
ByteBufAllocator
WrappedByteBuf. alloc()
Methods in io.netty.buffer with parameters of type ByteBufAllocator Modifier and Type Method Description static ByteBuf
ByteBufUtil. encodeString(ByteBufAllocator alloc, java.nio.CharBuffer src, java.nio.charset.Charset charset)
Encode the givenCharBuffer
using the givenCharset
into a newByteBuf
which is allocated via theByteBufAllocator
.static ByteBuf
ByteBufUtil. encodeString(ByteBufAllocator alloc, java.nio.CharBuffer src, java.nio.charset.Charset charset, int extraCapacity)
Encode the givenCharBuffer
using the givenCharset
into a newByteBuf
which is allocated via theByteBufAllocator
.static ByteBuf
ByteBufUtil. readBytes(ByteBufAllocator alloc, ByteBuf buffer, int length)
Read the given amount of bytes into a newByteBuf
that is allocated from theByteBufAllocator
.static ByteBuf
ByteBufUtil. writeAscii(ByteBufAllocator alloc, java.lang.CharSequence seq)
static ByteBuf
ByteBufUtil. writeUtf8(ByteBufAllocator alloc, java.lang.CharSequence seq)
Constructors in io.netty.buffer with parameters of type ByteBufAllocator Constructor Description CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents)
CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, ByteBuf... buffers)
CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, java.lang.Iterable<ByteBuf> buffers)
EmptyByteBuf(ByteBufAllocator alloc)
UnpooledDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)
Creates a new direct buffer.UnpooledDirectByteBuf(ByteBufAllocator alloc, java.nio.ByteBuffer initialBuffer, int maxCapacity)
Creates a new direct buffer by wrapping the specified initial buffer.UnpooledHeapByteBuf(ByteBufAllocator alloc, byte[] initialArray, int maxCapacity)
Creates a new heap buffer with an existing byte array.UnpooledHeapByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)
Creates a new heap buffer with a newly allocated byte array.UnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)
Creates a new direct buffer.UnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, java.nio.ByteBuffer initialBuffer, int maxCapacity)
Creates a new direct buffer by wrapping the specified initial buffer.UnpooledUnsafeHeapByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)
Creates a new heap buffer with a newly allocated byte array. -
Uses of ByteBufAllocator in io.netty.channel
Classes in io.netty.channel that implement ByteBufAllocator Modifier and Type Class Description class
PreferHeapByteBufAllocator
Wraps anotherByteBufAllocator
and use heapbuffers everywhere except when a direct buffer is explicit requested.Fields in io.netty.channel with type parameters of type ByteBufAllocator Modifier and Type Field Description static ChannelOption<ByteBufAllocator>
ChannelOption. ALLOCATOR
Methods in io.netty.channel that return ByteBufAllocator Modifier and Type Method Description default ByteBufAllocator
Channel. alloc()
Return the assignedByteBufAllocator
which will be used to allocateByteBuf
s.ByteBufAllocator
ChannelHandlerContext. alloc()
Return the assignedByteBufAllocator
which will be used to allocateByteBuf
s.ByteBufAllocator
ChannelConfig. getAllocator()
ReturnsByteBufAllocator
which is used for the channel to allocate buffers.ByteBufAllocator
DefaultChannelConfig. getAllocator()
Methods in io.netty.channel with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBuf
DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle. allocate(ByteBufAllocator alloc)
ByteBuf
RecvByteBufAllocator.DelegatingHandle. allocate(ByteBufAllocator alloc)
ByteBuf
RecvByteBufAllocator.Handle. allocate(ByteBufAllocator alloc)
Deprecated.Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.protected abstract ByteBuf
AbstractCoalescingBufferQueue. compose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)
Calculate the result ofcurrent + next
.protected ByteBuf
CoalescingBufferQueue. compose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)
protected ByteBuf
AbstractCoalescingBufferQueue. composeFirst(ByteBufAllocator allocator, ByteBuf first)
Deprecated.Use {AbstractCoalescingBufferQueue#composeFirst(ByteBufAllocator, ByteBuf, int)}protected ByteBuf
AbstractCoalescingBufferQueue. composeFirst(ByteBufAllocator allocator, ByteBuf first, int bufferSize)
Calculate the firstByteBuf
which will be used in subsequent calls toAbstractCoalescingBufferQueue.compose(ByteBufAllocator, ByteBuf, ByteBuf)
.protected ByteBuf
AbstractCoalescingBufferQueue. composeIntoComposite(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)
protected ByteBuf
AbstractCoalescingBufferQueue. copyAndCompose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)
ByteBuf
AbstractCoalescingBufferQueue. remove(ByteBufAllocator alloc, int bytes, ChannelPromise aggregatePromise)
Remove aByteBuf
from the queue with the specified number of bytes.ChannelConfig
ChannelConfig. setAllocator(ByteBufAllocator allocator)
Set theByteBufAllocator
which is used for the channel to allocate buffers.ChannelConfig
DefaultChannelConfig. setAllocator(ByteBufAllocator allocator)
Constructors in io.netty.channel with parameters of type ByteBufAllocator Constructor Description PreferHeapByteBufAllocator(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.channel.epoll
Methods in io.netty.channel.epoll with parameters of type ByteBufAllocator Modifier and Type Method Description EpollChannelConfig
EpollChannelConfig. setAllocator(ByteBufAllocator allocator)
EpollDatagramChannelConfig
EpollDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
EpollDomainDatagramChannelConfig
EpollDomainDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
EpollDomainSocketChannelConfig
EpollDomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
EpollServerChannelConfig
EpollServerChannelConfig. setAllocator(ByteBufAllocator allocator)
EpollServerSocketChannelConfig
EpollServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
EpollSocketChannelConfig
EpollSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.channel.kqueue
Methods in io.netty.channel.kqueue with parameters of type ByteBufAllocator Modifier and Type Method Description KQueueChannelConfig
KQueueChannelConfig. setAllocator(ByteBufAllocator allocator)
KQueueDatagramChannelConfig
KQueueDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
KQueueDomainDatagramChannelConfig
KQueueDomainDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
KQueueDomainSocketChannelConfig
KQueueDomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
KQueueServerChannelConfig
KQueueServerChannelConfig. setAllocator(ByteBufAllocator allocator)
KQueueServerSocketChannelConfig
KQueueServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
KQueueSocketChannelConfig
KQueueSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.channel.rxtx
Methods in io.netty.channel.rxtx with parameters of type ByteBufAllocator Modifier and Type Method Description RxtxChannelConfig
RxtxChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated. -
Uses of ByteBufAllocator in io.netty.channel.sctp
Methods in io.netty.channel.sctp with parameters of type ByteBufAllocator Modifier and Type Method Description SctpChannelConfig
DefaultSctpChannelConfig. setAllocator(ByteBufAllocator allocator)
SctpServerChannelConfig
DefaultSctpServerChannelConfig. setAllocator(ByteBufAllocator allocator)
SctpChannelConfig
SctpChannelConfig. setAllocator(ByteBufAllocator allocator)
SctpServerChannelConfig
SctpServerChannelConfig. setAllocator(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.channel.socket
Methods in io.netty.channel.socket with parameters of type ByteBufAllocator Modifier and Type Method Description DatagramChannelConfig
DatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
DatagramChannelConfig
DefaultDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
ServerSocketChannelConfig
DefaultServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
SocketChannelConfig
DefaultSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
DuplexChannelConfig
DuplexChannelConfig. setAllocator(ByteBufAllocator allocator)
ServerSocketChannelConfig
ServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
SocketChannelConfig
SocketChannelConfig. setAllocator(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.channel.socket.oio
Methods in io.netty.channel.socket.oio with parameters of type ByteBufAllocator Modifier and Type Method Description OioServerSocketChannelConfig
DefaultOioServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.OioSocketChannelConfig
DefaultOioSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.OioDatagramChannelConfig
OioDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.OioServerSocketChannelConfig
OioServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.OioSocketChannelConfig
OioSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated. -
Uses of ByteBufAllocator in io.netty.channel.udt
Methods in io.netty.channel.udt with parameters of type ByteBufAllocator Modifier and Type Method Description UdtChannelConfig
DefaultUdtChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.UdtServerChannelConfig
DefaultUdtServerChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.UdtChannelConfig
UdtChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated.UdtServerChannelConfig
UdtServerChannelConfig. setAllocator(ByteBufAllocator allocator)
Deprecated. -
Uses of ByteBufAllocator in io.netty.channel.unix
Classes in io.netty.channel.unix that implement ByteBufAllocator Modifier and Type Class Description class
PreferredDirectByteBufAllocator
Methods in io.netty.channel.unix that return ByteBufAllocator Modifier and Type Method Description protected abstract ByteBufAllocator
SocketWritableByteChannel. alloc()
Methods in io.netty.channel.unix with parameters of type ByteBufAllocator Modifier and Type Method Description DomainDatagramChannelConfig
DomainDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)
DomainSocketChannelConfig
DomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator)
void
PreferredDirectByteBufAllocator. updateAllocator(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.channel.uring
Constructors in io.netty.channel.uring with parameters of type ByteBufAllocator Constructor Description IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator)
Creates new instance.IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator, int minimum, int initial, int maximum)
Creates new instance.IoUringFixedBufferRingAllocator(ByteBufAllocator allocator, int bufferSize)
Create a new instance -
Uses of ByteBufAllocator in io.netty.handler.codec
Methods in io.netty.handler.codec with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBuf
ByteToMessageDecoder.Cumulator. cumulate(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf in)
-
Uses of ByteBufAllocator in io.netty.handler.codec.base64
Methods in io.netty.handler.codec.base64 with parameters of type ByteBufAllocator Modifier and Type Method Description static ByteBuf
Base64. decode(ByteBuf src, int off, int len, Base64Dialect dialect, ByteBufAllocator allocator)
static ByteBuf
Base64. encode(ByteBuf src, int off, int len, boolean breakLines, Base64Dialect dialect, ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.handler.codec.http
Methods in io.netty.handler.codec.http with parameters of type ByteBufAllocator Modifier and Type Method Description HttpContent
HttpChunkedInput. readChunk(ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.handler.codec.http.multipart
Methods in io.netty.handler.codec.http.multipart with parameters of type ByteBufAllocator Modifier and Type Method Description HttpContent
HttpPostRequestEncoder. readChunk(ByteBufAllocator allocator)
Returns the next available HttpChunk. -
Uses of ByteBufAllocator in io.netty.handler.codec.http.websocketx
Methods in io.netty.handler.codec.http.websocketx with parameters of type ByteBufAllocator Modifier and Type Method Description WebSocketFrame
WebSocketChunkedInput. readChunk(ByteBufAllocator allocator)
Fetches a chunked data from the stream. -
Uses of ByteBufAllocator in io.netty.handler.codec.http2
Methods in io.netty.handler.codec.http2 with parameters of type ByteBufAllocator Modifier and Type Method Description protected FullHttpMessage
InboundHttp2ToHttpAdapter. newMessage(Http2Stream stream, Http2Headers headers, boolean validateHttpHeaders, ByteBufAllocator alloc)
Create a newFullHttpMessage
based upon the current connection parametersHttp2DataFrame
Http2DataChunkedInput. readChunk(ByteBufAllocator allocator)
static FullHttpRequest
HttpConversionUtil. toFullHttpRequest(int streamId, Http2Headers http2Headers, ByteBufAllocator alloc, boolean validateHttpHeaders)
Create a new object to contain the request datastatic FullHttpResponse
HttpConversionUtil. toFullHttpResponse(int streamId, Http2Headers http2Headers, ByteBufAllocator alloc, boolean validateHttpHeaders)
Create a new object to contain the response data -
Uses of ByteBufAllocator in io.netty.handler.codec.spdy
Methods in io.netty.handler.codec.spdy with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBuf
SpdyHeaderBlockRawEncoder. encode(ByteBufAllocator alloc, SpdyHeadersFrame frame)
ByteBuf
SpdyFrameEncoder. encodeDataFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf data)
ByteBuf
SpdyFrameEncoder. encodeGoAwayFrame(ByteBufAllocator allocator, int lastGoodStreamId, int statusCode)
ByteBuf
SpdyFrameEncoder. encodeHeadersFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf headerBlock)
ByteBuf
SpdyFrameEncoder. encodePingFrame(ByteBufAllocator allocator, int id)
ByteBuf
SpdyFrameEncoder. encodeRstStreamFrame(ByteBufAllocator allocator, int streamId, int statusCode)
ByteBuf
SpdyFrameEncoder. encodeSettingsFrame(ByteBufAllocator allocator, SpdySettingsFrame spdySettingsFrame)
ByteBuf
SpdyFrameEncoder. encodeSynReplyFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf headerBlock)
ByteBuf
SpdyFrameEncoder. encodeSynStreamFrame(ByteBufAllocator allocator, int streamId, int associatedToStreamId, byte priority, boolean last, boolean unidirectional, ByteBuf headerBlock)
ByteBuf
SpdyFrameEncoder. encodeUnknownFrame(ByteBufAllocator allocator, int frameType, byte flags, ByteBuf data)
ByteBuf
SpdyFrameEncoder. encodeWindowUpdateFrame(ByteBufAllocator allocator, int streamId, int deltaWindowSize)
-
Uses of ByteBufAllocator in io.netty.handler.ssl
Methods in io.netty.handler.ssl with parameters of type ByteBufAllocator Modifier and Type Method Description javax.net.ssl.SSLEngine
DelegatingSslContext. newEngine(ByteBufAllocator alloc)
javax.net.ssl.SSLEngine
DelegatingSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)
javax.net.ssl.SSLEngine
JdkSslContext. newEngine(ByteBufAllocator alloc)
javax.net.ssl.SSLEngine
JdkSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)
javax.net.ssl.SSLEngine
ReferenceCountedOpenSslContext. newEngine(ByteBufAllocator alloc)
Returns a new server-sideSSLEngine
with the current configuration.javax.net.ssl.SSLEngine
ReferenceCountedOpenSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)
abstract javax.net.ssl.SSLEngine
SslContext. newEngine(ByteBufAllocator alloc)
Creates a newSSLEngine
.abstract javax.net.ssl.SSLEngine
SslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)
Creates a newSSLEngine
using advisory peer information.protected SslHandler
DelegatingSslContext. newHandler(ByteBufAllocator alloc, boolean startTls)
protected SslHandler
DelegatingSslContext. newHandler(ByteBufAllocator alloc, boolean startTls, java.util.concurrent.Executor executor)
protected SslHandler
DelegatingSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls)
protected SslHandler
DelegatingSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls, java.util.concurrent.Executor executor)
protected SslHandler
ReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, boolean startTls)
protected SslHandler
ReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, boolean startTls, java.util.concurrent.Executor executor)
protected SslHandler
ReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls)
protected SslHandler
ReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls, java.util.concurrent.Executor executor)
SslHandler
SslContext. newHandler(ByteBufAllocator alloc)
Create a new SslHandler.protected SslHandler
SslContext. newHandler(ByteBufAllocator alloc, boolean startTls)
Create a new SslHandler.protected SslHandler
SslContext. newHandler(ByteBufAllocator alloc, boolean startTls, java.util.concurrent.Executor executor)
Create a new SslHandler.SslHandler
SslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)
Creates a newSslHandler
protected SslHandler
SslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls)
Create a new SslHandler.protected SslHandler
SslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls, java.util.concurrent.Executor delegatedTaskExecutor)
SslHandler
SslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, java.util.concurrent.Executor delegatedTaskExecutor)
Creates a newSslHandler
with advisory peer information.SslHandler
SslContext. newHandler(ByteBufAllocator alloc, java.util.concurrent.Executor delegatedTaskExecutor)
Creates a newSslHandler
.protected SslHandler
SniHandler. newSslHandler(SslContext context, ByteBufAllocator allocator)
-
Uses of ByteBufAllocator in io.netty.handler.stream
Methods in io.netty.handler.stream with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBuf
ChunkedFile. readChunk(ByteBufAllocator allocator)
B
ChunkedInput. readChunk(ByteBufAllocator allocator)
Fetches a chunked data from the stream.ByteBuf
ChunkedNioFile. readChunk(ByteBufAllocator allocator)
ByteBuf
ChunkedNioStream. readChunk(ByteBufAllocator allocator)
ByteBuf
ChunkedStream. readChunk(ByteBufAllocator allocator)
-