Package org.jline.utils

Class PumpReader

java.lang.Object

java.io.Reader

org.jline.utils.PumpReader

All Implemented Interfaces:

Closeable, AutoCloseable, Readable

public class PumpReader
extends Reader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	PumpReader.InputStream
private static class	PumpReader.Writer

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private static final int	DEFAULT_BUFFER_SIZE
private static final int	EOF
private final CharBuffer	readBuffer
private final CharBuffer	writeBuffer
private final PumpReader.Writer	writer

Fields inherited from class java.io.Reader

lock

Constructor Summary

Constructors

Constructor	Description
PumpReader()
PumpReader(int bufferSize)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
private int	copyFromBuffer(char[] cbuf, int off, int len)
InputStream	createInputStream(Charset charset)
private void	encodeBytes(CharsetEncoder encoder, ByteBuffer output)
(package private) void	flush()
Writer	getWriter()
int	read()
int	read(char[] cbuf, int off, int len)
int	read(CharBuffer target)
(package private) int	readBytes(CharsetEncoder encoder, byte[] b, int off, int len)
(package private) void	readBytes(CharsetEncoder encoder, ByteBuffer output)
boolean	ready()
private static boolean	rewind(CharBuffer buffer, CharBuffer other)
private boolean	rewindReadBuffer()	Attempts to find additional input by rewinding the readBuffer.
private void	rewindWriteBuffer()	Attempts to find additional buffer space by rewinding the writeBuffer.
private boolean	wait(CharBuffer buffer)	Waits until buffer.hasRemaining() == true, or it is false and the reader is closed.
private void	waitForBufferSpace()	Blocks until there is new space available for buffering or the reader is closed.
private boolean	waitForInput()	Blocks until input is available or the reader is closed.
private boolean	waitForMoreInput()	Blocks until more input is available, even if readBuffer already contains some chars; or until the reader is closed.
(package private) void	write(char c)
(package private) void	write(char[] cbuf, int off, int len)
(package private) void	write(String str, int off, int len)

Methods inherited from class java.io.Reader

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

Methods inherited from class java.lang.Object

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

Field Details

EOF

private static final int EOF

See Also:

• Constant Field Values

DEFAULT_BUFFER_SIZE

private static final int DEFAULT_BUFFER_SIZE

See Also:

• Constant Field Values

readBuffer

private final CharBuffer readBuffer

writeBuffer

private final CharBuffer writeBuffer

writer

private final PumpReader.Writer writer

closed

private boolean closed

Constructor Details

PumpReader

public PumpReader()

PumpReader

public PumpReader(int bufferSize)

Method Details

getWriter

public Writer getWriter()

createInputStream

public InputStream createInputStream(Charset charset)

waitForMoreInput

private boolean waitForMoreInput()
                          throws InterruptedIOException

Blocks until more input is available, even if readBuffer already contains some chars; or until the reader is closed.

Returns:

true if more input is available, false if no additional input is available and the reader is closed

Throws:

InterruptedIOException - If Object.wait() is interrupted

wait

private boolean wait(CharBuffer buffer)
              throws InterruptedIOException

Waits until buffer.hasRemaining() == true, or it is false and the reader is closed.

Returns:

true if buffer.hasRemaining() == true; false otherwise when reader is closed

Throws:

InterruptedIOException

waitForInput

private boolean waitForInput()
                      throws InterruptedIOException

Blocks until input is available or the reader is closed.

Returns:

true if input is available, false if no input is available and the reader is closed

Throws:

InterruptedIOException - If Object.wait() is interrupted

waitForBufferSpace

private void waitForBufferSpace()
                         throws InterruptedIOException,
ClosedException

Blocks until there is new space available for buffering or the reader is closed.

Throws:

InterruptedIOException - If Object.wait() is interrupted

ClosedException - If the reader was closed

rewind

private static boolean rewind(CharBuffer buffer,
 CharBuffer other)

rewindReadBuffer

private boolean rewindReadBuffer()

Attempts to find additional input by rewinding the readBuffer. Updates the writeBuffer to make read bytes available for buffering.

Returns:

If more input is available

rewindWriteBuffer

private void rewindWriteBuffer()

Attempts to find additional buffer space by rewinding the writeBuffer. Updates the readBuffer to make written bytes available to the reader.

ready

public boolean ready()

Overrides:

ready in class Reader

available

public int available()

read

public int read()
         throws IOException

Overrides:

read in class Reader

Throws:

IOException

copyFromBuffer

private int copyFromBuffer(char[] cbuf,
 int off,
 int len)

read

public int read(char[] cbuf,
 int off,
 int len)
         throws IOException

Specified by:

read in class Reader

Throws:

IOException

read

public int read(CharBuffer target)
         throws IOException

Specified by:

read in interface Readable

Overrides:

read in class Reader

Throws:

IOException

encodeBytes

private void encodeBytes(CharsetEncoder encoder,
 ByteBuffer output)
                  throws IOException

Throws:

IOException

readBytes

int readBytes(CharsetEncoder encoder,
 byte[] b,
 int off,
 int len)
       throws IOException

Throws:

IOException

readBytes

void readBytes(CharsetEncoder encoder,
 ByteBuffer output)
        throws IOException

Throws:

IOException

write

void write(char c)
    throws IOException

Throws:

IOException

write

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

Throws:

IOException

write

void write(String str,
 int off,
 int len)
    throws IOException

Throws:

IOException

flush

void flush()

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