Package org.jline.utils

Class NonBlockingPumpInputStream

java.lang.Object

java.io.InputStream

org.jline.utils.NonBlockingInputStream

org.jline.utils.NonBlockingPumpInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class NonBlockingPumpInputStream
extends NonBlockingInputStream

Field Summary

Fields inherited from class org.jline.utils.NonBlockingInputStream

closed, EOF, READ_EXPIRED

Constructor Summary

Constructors

Constructor	Description
NonBlockingPumpInputStream()
NonBlockingPumpInputStream(int bufferSize)

Method Summary

Modifier and Type	Method	Description
int	available()
protected void	checkIoException()
void	close()	Closes this input stream and marks it as closed.
void	closeWriter()	Signals that the write side has been closed and no more data will be written.
OutputStream	getOutputStream()
int	read(byte[] b, int off, int len)
int	read(long timeout, boolean isPeek)
int	readBuffered(byte[] b, int off, int len, long timeout)
void	setIoException(IOException exception)

Methods inherited from class org.jline.utils.NonBlockingInputStream

checkClosed, peek, read, read, readBuffered, readBuffered, setPollFunction, shutdown

Methods inherited from class java.io.InputStream

mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

NonBlockingPumpInputStream

public NonBlockingPumpInputStream()

NonBlockingPumpInputStream

public NonBlockingPumpInputStream(int bufferSize)

Method Details

getOutputStream

public OutputStream getOutputStream()

available

public int available()

Overrides:

available in class InputStream

read

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

Overrides:

read in class NonBlockingInputStream

Throws:

IOException

read

public int read(long timeout,
 boolean isPeek)
         throws IOException

Specified by:

read in class NonBlockingInputStream

Throws:

IOException

readBuffered

public int readBuffered(byte[] b,
 int off,
 int len,
 long timeout)
                 throws IOException

Overrides:

readBuffered in class NonBlockingInputStream

Throws:

IOException

setIoException

public void setIoException(IOException exception)

checkIoException

protected void checkIoException()
                         throws IOException

Throws:

IOException

closeWriter

public void closeWriter()

Signals that the write side has been closed and no more data will be written. Any buffered data can still be read; reads will return NonBlockingInputStream.EOF only after all buffered data has been consumed. This is analogous to closing the write end of a Unix pipe: the read end drains remaining data before seeing EOF.

close

public void close()
           throws IOException

Description copied from class: NonBlockingInputStream

Closes this input stream and marks it as closed.

Subsequent read operations behavior depends on the PROP_CLOSE_MODE setting:

• "strict" - Throw ClosedException (default in JLine 4.x)
• "warn" - Log a warning but continue (default in JLine 3.x)
• "lenient" - Silently allow access

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class NonBlockingInputStream

Throws:

IOException - if an I/O error occurs