Package org.jline.utils

Class NonBlockingPumpReader

java.lang.Object

java.io.Reader

org.jline.utils.NonBlockingReader

org.jline.utils.NonBlockingPumpReader

All Implemented Interfaces:

Closeable, AutoCloseable, Readable

public class NonBlockingPumpReader
extends NonBlockingReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	NonBlockingPumpReader.NbpWriter

Field Summary

Fields

Modifier and Type	Field	Description
private final char[]	buffer
private boolean	closed
private int	count
private static final int	DEFAULT_BUFFER_SIZE
(package private) final ReentrantLock	lock	Main lock guarding all access
private final Condition	notEmpty	Condition for waiting takes
private final Condition	notFull	Condition for waiting puts
private int	read
private int	write
private final Writer	writer

Fields inherited from class org.jline.utils.NonBlockingReader

EOF, READ_EXPIRED

Constructor Summary

Constructors

Constructor	Description
NonBlockingPumpReader()
NonBlockingPumpReader(int bufferSize)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
Writer	getWriter()
protected int	read(long timeout, boolean isPeek)	Attempts to read a character from the input stream for a specific period of time.
int	readBuffered(char[] b, int off, int len, long timeout)
boolean	ready()
(package private) void	write(char[] cbuf, int off, int len)

Methods inherited from class org.jline.utils.NonBlockingReader

peek, read, read, read, readBuffered, readBuffered, shutdown

Methods inherited from class java.io.Reader

mark, markSupported, nullReader, read, read, reset, skip, transferTo

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_BUFFER_SIZE

private static final int DEFAULT_BUFFER_SIZE

See Also:

• Constant Field Values

buffer

private final char[] buffer

read

private int read

write

private int write

count

private int count

lock

final ReentrantLock lock

Main lock guarding all access

notEmpty

private final Condition notEmpty

Condition for waiting takes

notFull

private final Condition notFull

Condition for waiting puts

writer

private final Writer writer

closed

private boolean closed

Constructor Details

NonBlockingPumpReader

public NonBlockingPumpReader()

NonBlockingPumpReader

public NonBlockingPumpReader(int bufferSize)

Method Details

getWriter

public Writer getWriter()

ready

public boolean ready()

Overrides:

ready in class Reader

available

public int available()

Overrides:

available in class NonBlockingReader

read

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

Description copied from class: NonBlockingReader

Attempts to read a character from the input stream for a specific period of time.

Specified by:

read in class NonBlockingReader

Parameters:

timeout - The amount of time to wait for the character

isPeek - trueif the character read must not be consumed

Returns:

The character read, -1 if EOF is reached, or -2 if the read timed out.

Throws:

IOException - if anything wrong happens

readBuffered

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

Specified by:

readBuffered in class NonBlockingReader

Throws:

IOException

write

void write(char[] cbuf,
 int off,
 int len)
    throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class Reader

Throws:

IOException