public class NettyInputStream extends InputStream
Converts Netty NIO buffers to an input streams and stores them in the queue, waiting for Jersey to process it.
Constructor and Description |
---|
NettyInputStream() |
Modifier and Type | Method and Description |
---|---|
int |
available() |
protected ByteBuffer |
awaitNext() |
protected void |
cleanup(boolean drain) |
void |
clear() |
void |
close() |
void |
complete(Throwable cause) |
void |
publish(io.netty.buffer.ByteBuf content) |
int |
read() |
int |
read(byte[] b,
int off,
int len) |
mark, markSupported, read, reset, skip
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
IOException
public int read() throws IOException
read
in class InputStream
IOException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
protected ByteBuffer awaitNext()
public void complete(Throwable cause)
protected void cleanup(boolean drain)
public int available() throws IOException
available
in class InputStream
IOException
public void publish(io.netty.buffer.ByteBuf content)
public void clear()
Copyright © 2007-2023, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.