public class ChunkedNioStream extends java.lang.Object implements ChunkedInput<ByteBuf>
| Constructor and Description |
|---|
ChunkedNioStream(java.nio.channels.ReadableByteChannel in)
创建一个从指定通道获取数据的新实例。
|
ChunkedNioStream(java.nio.channels.ReadableByteChannel in, int chunkSize)
创建一个从指定通道获取数据的新实例。
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
释放与输入相关的资源。
|
boolean |
isEndOfInput()
返回
true当且仅当数据流中没有剩余数据且数据流已达到数据结束时。
|
long |
length()
返回输入的长度。
|
long |
progress()
返回当前传输进度。
|
ByteBuf |
readChunk(ByteBufAllocator allocator)
从流中获取分块的数据。
|
ByteBuf |
readChunk(ChannelHandlerContext ctx)
已过时。
|
long |
transferredBytes()
返回传输的字节数。
|
public ChunkedNioStream(java.nio.channels.ReadableByteChannel in)
public ChunkedNioStream(java.nio.channels.ReadableByteChannel in,
int chunkSize)
chunkSize - 每个
readChunk(ChannelHandlerContext)调用中要获取的字节数
public long transferredBytes()
public boolean isEndOfInput()
throws java.lang.Exception
ChunkedInput复制的描述
true当且仅当数据流中没有剩余数据且数据流已达到其结尾时。
isEndOfInput ,界面
ChunkedInput<ByteBuf>
java.lang.Exception
public void close()
throws java.lang.Exception
ChunkedInput
close在界面
ChunkedInput<ByteBuf>
java.lang.Exception
@Deprecated public ByteBuf readChunk(ChannelHandlerContext ctx) throws java.lang.Exception
readChunk在界面
ChunkedInput<ByteBuf>
ctx -它提供了一个上下文ByteBufAllocator如果缓冲区分配是必要的。
null如果数据流中没有剩余数据。
请注意, null并不一定意味着该流已到达结尾。
在缓慢的流中,下一个块可能暂时不可用。
java.lang.Exception
public ByteBuf readChunk(ByteBufAllocator allocator) throws java.lang.Exception
ChunkedInput复制的描述
ChunkedInput.isEndOfInput()调用都必须返回true 。
readChunk在界面
ChunkedInput<ByteBuf>
allocator - ByteBufAllocator如果缓冲区分配是必要的。
null如果数据流中没有剩余数据。
请注意, null并不一定表示该流已到达其结尾。
在缓慢的流中,下一个块可能暂时不可用。
java.lang.Exception
public long length()
ChunkedInput
length在界面
ChunkedInput<ByteBuf>
public long progress()
ChunkedInput
progress ,界面
ChunkedInput<ByteBuf>
Copyright © 2008–2018 The Netty Project. All rights reserved.