public class ChannelPipedInputStream extends InputStream implements ChannelPipedSink
Constructor and Description |
---|
ChannelPipedInputStream(PropertyResolver resolver,
Window localWindow) |
ChannelPipedInputStream(Window localWindow,
long windowTimeout) |
Modifier and Type | Method and Description |
---|---|
int |
available() |
void |
close() |
void |
eof()
Signal end of writing to the sink
|
long |
getTimeout() |
boolean |
isOpen() |
int |
read() |
int |
read(byte[] b,
int off,
int len) |
void |
receive(byte[] bytes,
int off,
int len) |
void |
setTimeout(long timeout) |
mark, markSupported, read, reset, skip
public ChannelPipedInputStream(PropertyResolver resolver, Window localWindow)
public ChannelPipedInputStream(Window localWindow, long windowTimeout)
public void setTimeout(long timeout)
public long getTimeout()
public int available() throws IOException
available
in class InputStream
IOException
public int read() throws IOException
read
in class InputStream
IOException
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
IOException
public void eof()
ChannelPipedSink
eof
in interface ChannelPipedSink
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface Channel
close
in class InputStream
IOException
public void receive(byte[] bytes, int off, int len) throws IOException
receive
in interface ChannelPipedSink
bytes
- Bytes to be sent to the sinkoff
- Offset in bufferlen
- Number of bytesIOException
- If failed to send the dataCopyright © 2008–2016 The Apache Software Foundation. All rights reserved.