- java.lang.Object
-
- io.netty5.handler.codec.http2.Http2DataChunkedInput
-
- All Implemented Interfaces:
ChunkedInput<Http2DataFrame>
,AutoCloseable
public final class Http2DataChunkedInput extends Object implements ChunkedInput<Http2DataFrame>
AChunkedInput
that fetches data chunk by chunk for use with HTTP/2 Data Frames.Each chunk from the input data will be wrapped within a
Http2DataFrame
. At the end of the input data,Http2DataFrame.isEndStream()
will be set to true and will be written.public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { if (msg instanceof Http2HeadersFrame) { Http2HeadersFrame http2HeadersFrame = (Http2HeadersFrame) msg; Http2HeadersFrame response = new DefaultHttp2HeadersFrame(new DefaultHttp2Headers().status("200")); response.stream(http2HeadersFrame.stream()); ctx.write(response); ChannelFuture sendFileFuture = ctx.writeAndFlush(new Http2DataChunkedInput( new ChunkedFile(new File(("/home/meow/cats.mp4"))), http2HeadersFrame.stream())); } }
-
-
Constructor Summary
Constructors Constructor Description Http2DataChunkedInput(ChunkedInput<Buffer> input, Http2FrameStream stream)
Creates a new instance using the specified input.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
boolean
isEndOfInput()
Returntrue
if and only if there is no data left in the stream and the stream has reached at its end.long
length()
Returns the length of the input.long
progress()
Returns current transfer progress.Http2DataFrame
readChunk(BufferAllocator allocator)
Fetches a chunked data from the stream.
-
-
-
Constructor Detail
-
Http2DataChunkedInput
public Http2DataChunkedInput(ChunkedInput<Buffer> input, Http2FrameStream stream)
Creates a new instance using the specified input.- Parameters:
input
-ChunkedInput
containing data to writestream
-Http2FrameStream
holding stream info
-
-
Method Detail
-
isEndOfInput
public boolean isEndOfInput() throws Exception
Description copied from interface:ChunkedInput
Returntrue
if and only if there is no data left in the stream and the stream has reached at its end.- Specified by:
isEndOfInput
in interfaceChunkedInput<Http2DataFrame>
- Throws:
Exception
-
close
public void close() throws Exception
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
-
readChunk
public Http2DataFrame readChunk(BufferAllocator allocator) throws Exception
Description copied from interface:ChunkedInput
Fetches a chunked data from the stream. Once this method returns the last chunk and thus the stream has reached at its end, any subsequentChunkedInput.isEndOfInput()
call must returntrue
.- Specified by:
readChunk
in interfaceChunkedInput<Http2DataFrame>
- Parameters:
allocator
-BufferAllocator
if buffer allocation is necessary.- Returns:
- the fetched chunk.
null
if there is no data left in the stream. Please note thatnull
does not necessarily mean that the stream has reached at its end. In a slow stream, the next chunk might be unavailable just momentarily. - Throws:
Exception
-
length
public long length()
Description copied from interface:ChunkedInput
Returns the length of the input.- Specified by:
length
in interfaceChunkedInput<Http2DataFrame>
- Returns:
- the length of the input if the length of the input is known. a negative value if the length of the input is unknown.
-
progress
public long progress()
Description copied from interface:ChunkedInput
Returns current transfer progress.- Specified by:
progress
in interfaceChunkedInput<Http2DataFrame>
-
-