org.glassfish.jersey.netty.connector.internal

Class JerseyChunkedInput

java.lang.Object

java.io.OutputStream

org.glassfish.jersey.netty.connector.internal.JerseyChunkedInput

All Implemented Interfaces:

io.netty.channel.ChannelFutureListener, io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>, io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>, Closeable, Flushable, AutoCloseable, EventListener

public class JerseyChunkedInput
extends OutputStream
implements io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf>, io.netty.channel.ChannelFutureListener

Netty ChunkedInput implementation which also serves as an output stream to Jersey ContainerResponseContext.

Author:

Pavel Bucek

Field Summary

Fields inherited from interface io.netty.channel.ChannelFutureListener

CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE

Constructor Summary

Constructors

Constructor and Description
JerseyChunkedInput(io.netty.channel.Channel ctx)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush()
boolean	isEndOfInput()
long	length()
void	operationComplete(io.netty.channel.ChannelFuture f)
long	progress()
io.netty.buffer.ByteBuf	readChunk(io.netty.buffer.ByteBufAllocator allocator)
io.netty.buffer.ByteBuf	readChunk(io.netty.channel.ChannelHandlerContext ctx) Deprecated.
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.lang.Object

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

Constructor Detail

JerseyChunkedInput

public JerseyChunkedInput(io.netty.channel.Channel ctx)

Method Detail

isEndOfInput

public boolean isEndOfInput()
                     throws Exception

Specified by:

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

Throws:

Exception

operationComplete

public void operationComplete(io.netty.channel.ChannelFuture f)
                       throws Exception

Specified by:

operationComplete in interface io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>

Throws:

Exception

readChunk

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

Deprecated.

Specified by:

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

Throws:

Exception

readChunk

public io.netty.buffer.ByteBuf readChunk(io.netty.buffer.ByteBufAllocator allocator)
                                  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>

close

public void close()
           throws IOException

Specified by:

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

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class OutputStream

Throws:

IOException

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException