org.waarp.gateway.kernel.commonfile

Class CommonFileChunkedInput

java.lang.Object

org.waarp.gateway.kernel.commonfile.CommonFileChunkedInput

All Implemented Interfaces:

io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

public class CommonFileChunkedInput
extends Object
implements io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

Constructor Summary

Constructors

Constructor and Description
CommonFileChunkedInput(FileInterface document)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isEndOfInput()
long	length()
long	progress()
io.netty.buffer.ByteBuf	readChunk(io.netty.buffer.ByteBufAllocator byteBufAllocator)
io.netty.buffer.ByteBuf	readChunk(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommonFileChunkedInput

public CommonFileChunkedInput(FileInterface document)
                       throws HttpIncorrectRetrieveException

Parameters:

document -

Throws:

HttpIncorrectRetrieveException

Method Detail

readChunk

public io.netty.buffer.ByteBuf readChunk(io.netty.channel.ChannelHandlerContext ctx)
                                  throws Exception

Specified by:

readChunk in interface io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

Throws:

Exception

length

public long length()

Specified by:

length in interface io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

progress

public long progress()

Specified by:

progress in interface io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

isEndOfInput

public boolean isEndOfInput()

Specified by:

isEndOfInput in interface io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

close

public void close()
           throws HttpIncorrectRetrieveException

Specified by:

close in interface io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

Throws:

HttpIncorrectRetrieveException

readChunk

public io.netty.buffer.ByteBuf readChunk(io.netty.buffer.ByteBufAllocator byteBufAllocator)
                                  throws Exception

Specified by:

readChunk in interface io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>

Throws:

Exception