public class ChannelPipedInputStream extends InputStream implements ChannelPipedSink
Constructor and Description |
---|
ChannelPipedInputStream(LocalWindow localWindow,
Duration windowTimeout) |
ChannelPipedInputStream(LocalWindow localWindow,
long windowTimeout) |
ChannelPipedInputStream(PropertyResolver resolver,
LocalWindow localWindow) |
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, LocalWindow localWindow)
public ChannelPipedInputStream(LocalWindow localWindow, Duration windowTimeout)
public ChannelPipedInputStream(LocalWindow 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–2024 The Apache Software Foundation. All rights reserved.