Modifier and Type	Class and Description
private class	NonBlockingPumpInputStream.NbpOutputStream

Modifier and Type	Field and Description
private boolean	closed
private static final int	DEFAULT_BUFFER_SIZE Hides java.io.InputStream.DEFAULT_BUFFER_SIZE.
private IOException	ioException
private final OutputStream	output
private final ByteBuffer	readBuffer
private final ByteBuffer	writeBuffer

Access	Constructor and Description
public	NonBlockingPumpInputStream()
public	NonBlockingPumpInputStream(int bufferSize)

Method Summary

Modifier and Type	Method and Description
public synchronized int	available() Overrides java.io.InputStream.available. Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected.
protected synchronized void	checkIoException()
public synchronized void	close() Overrides java.io.InputStream.close. Implements java.io.Closeable.close. Closes this input stream and releases any system resources associated with the stream.
pack-priv synchronized void	flush()
public OutputStream	getOutputStream()
public synchronized int	read(long timeout, boolean isPeek) Implements abstract jdk.internal.org.jline.utils.NonBlockingInputStream.read.
public synchronized int	readBuffered(byte[] b, int off, int len, long timeout) Overrides jdk.internal.org.jline.utils.NonBlockingInputStream.readBuffered.
private static boolean	rewind(ByteBuffer buffer, ByteBuffer other)
public synchronized void	setIoException(IOException exception)
private int	wait(ByteBuffer buffer, long timeout)
pack-priv synchronized void	write(byte[] cbuf, int off, int len)

Inherited from jdk.internal.org.jline.utils.NonBlockingInputStream:: peek read read read readBuffered readBuffered shutdown

Field Detail

closed	back to summary
private boolean closed

DEFAULT_BUFFER_SIZE	back to summary
private static final int DEFAULT_BUFFER_SIZE Hides java.io.InputStream.DEFAULT_BUFFER_SIZE.

ioException	back to summary
private IOException ioException

output	back to summary
private final OutputStream output

readBuffer	back to summary
private final ByteBuffer readBuffer

writeBuffer	back to summary
private final ByteBuffer writeBuffer

NonBlockingPumpInputStream	back to summary
public NonBlockingPumpInputStream()

NonBlockingPumpInputStream	back to summary
public NonBlockingPumpInputStream(int bufferSize)

Method Detail

available back to summary

available	back to summary
public synchronized int available() Overrides java.io.InputStream.available. Doc from java.io.InputStream.available. Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected. The read might be on the same thread or another thread. A single read or skip of this many bytes will not block, but may read or skip fewer bytes. Note that while some implementations of `InputStream` will return the total number of bytes in the stream, many will not. It is never correct to use the return value of this method to allocate a buffer intended to hold all data in this stream. A subclass's implementation of this method may choose to throw an `IOException` if this input stream has been closed by invoking the `close()` method.

public synchronized int available()

Overrides java.io.InputStream.available.

Doc from java.io.InputStream.available.

Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected. The read might be on the same thread or another thread. A single read or skip of this many bytes will not block, but may read or skip fewer bytes.

Note that while some implementations of InputStream will return the total number of bytes in the stream, many will not. It is never correct to use the return value of this method to allocate a buffer intended to hold all data in this stream.

A subclass's implementation of this method may choose to throw an IOException if this input stream has been closed by invoking the close() method.

checkIoException	back to summary
protected synchronized void checkIoException() throws IOException

close	back to summary
public synchronized void close() throws IOException Overrides java.io.InputStream.close. Implements java.io.Closeable.close. Doc from java.io.InputStream.close. Closes this input stream and releases any system resources associated with the stream. Annotations @Override Exceptions IOException: if an I/O error occurs.

back to summary

public synchronized void close() throws IOException

Overrides java.io.InputStream.close.

Implements java.io.Closeable.close.

Doc from java.io.InputStream.close.

Closes this input stream and releases any system resources associated with the stream.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

flush	back to summary
pack-priv synchronized void flush()

getOutputStream	back to summary
public OutputStream getOutputStream()

read	back to summary
public synchronized int read(long timeout, boolean isPeek) throws IOException Implements abstract jdk.internal.org.jline.utils.NonBlockingInputStream.read. Annotations @Override

read

back to summary

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

Implements abstract jdk.internal.org.jline.utils.NonBlockingInputStream.read.

Annotations

@Override

readBuffered	back to summary
public synchronized int readBuffered(byte[] b, int off, int len, long timeout) throws IOException Overrides jdk.internal.org.jline.utils.NonBlockingInputStream.readBuffered. Annotations @Override

readBuffered

back to summary

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

Overrides jdk.internal.org.jline.utils.NonBlockingInputStream.readBuffered.

Annotations

@Override

rewind	back to summary
private static boolean rewind(ByteBuffer buffer, ByteBuffer other)

setIoException	back to summary
public synchronized void setIoException(IOException exception)

wait	back to summary
private int wait(ByteBuffer buffer, long timeout) throws IOException

write	back to summary
pack-priv synchronized void write(byte[] cbuf, int off, int len) throws IOException

jdk.internal.org.jline.utils back to summary

private Class NonBlockingPumpInputStream.NbpOutputStream

Class Inheritance

extends OutputStream

java.lang.Object
java.io.OutputStream
jdk.internal.org.jline.utils.NonBlockingPumpInputStream.NbpOutputStream

Constructor Summary

Access	Constructor and Description
private	NbpOutputStream()

Method Summary

Modifier and Type	Method and Description
public void	close() Overrides java.io.OutputStream.close. Implements java.io.Closeable.close. Closes this output stream and releases any system resources associated with this stream.
public void	flush() Overrides java.io.OutputStream.flush. Implements java.io.Flushable.flush. Flushes this output stream and forces any buffered output bytes to be written out.
public void	write(int b) Implements abstract java.io.OutputStream.write. Writes the specified byte to this output stream.
public void	write(byte[] cbuf, int off, int len) Overrides java.io.OutputStream.write. Writes `len` bytes from the specified byte array starting at offset `off` to this output stream.

Inherited from java.io.OutputStream:: nullOutputStream write

Constructor Detail

NbpOutputStream	back to summary
private NbpOutputStream()

Method Detail

close back to summary

close	back to summary
public void close() throws IOException Overrides java.io.OutputStream.close. Implements java.io.Closeable.close. Doc from java.io.OutputStream.close. Closes this output stream and releases any system resources associated with this stream. The general contract of `close` is that it closes the output stream. A closed stream cannot perform output operations and cannot be reopened. Annotations @Override Exceptions IOException: if an I/O error occurs.

public void close() throws IOException

Overrides java.io.OutputStream.close.

Implements java.io.Closeable.close.

Doc from java.io.OutputStream.close.

Closes this output stream and releases any system resources associated with this stream. The general contract of close is that it closes the output stream. A closed stream cannot perform output operations and cannot be reopened.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

flush back to summary

flush	back to summary
public void flush() throws IOException Overrides java.io.OutputStream.flush. Implements java.io.Flushable.flush. Doc from java.io.OutputStream.flush. Flushes this output stream and forces any buffered output bytes to be written out. The general contract of `flush` is that calling it is an indication that, if any bytes previously written have been buffered by the implementation of the output stream, such bytes should immediately be written to their intended destination. If the intended destination of this stream is an abstraction provided by the underlying operating system, for example a file, then flushing the stream guarantees only that bytes previously written to the stream are passed to the operating system for writing; it does not guarantee that they are actually written to a physical device such as a disk drive. Annotations @Override Exceptions IOException: if an I/O error occurs.

public void flush() throws IOException

Overrides java.io.OutputStream.flush.

Implements java.io.Flushable.flush.

Doc from java.io.OutputStream.flush.

Flushes this output stream and forces any buffered output bytes to be written out. The general contract of flush is that calling it is an indication that, if any bytes previously written have been buffered by the implementation of the output stream, such bytes should immediately be written to their intended destination.

If the intended destination of this stream is an abstraction provided by the underlying operating system, for example a file, then flushing the stream guarantees only that bytes previously written to the stream are passed to the operating system for writing; it does not guarantee that they are actually written to a physical device such as a disk drive.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

write back to summary

write	back to summary
public void write(int b) throws IOException Implements abstract java.io.OutputStream.write. Doc from java.io.OutputStream.write. Writes the specified byte to this output stream. The general contract for `write` is that one byte is written to the output stream. The byte to be written is the eight low-order bits of the argument `b`. The 24 high-order bits of `b` are ignored. Annotations @Override Exceptions IOException: if an I/O error occurs. In particular, an `IOException` may be thrown if the output stream has been closed.

public void write(int b) throws IOException

Implements abstract java.io.OutputStream.write.

Doc from java.io.OutputStream.write.

Writes the specified byte to this output stream. The general contract for write is that one byte is written to the output stream. The byte to be written is the eight low-order bits of the argument b. The 24 high-order bits of b are ignored.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

write back to summary

write	back to summary
public void write(byte[] cbuf, int off, int len) throws IOException Overrides java.io.OutputStream.write. Doc from java.io.OutputStream.write. Writes `len` bytes from the specified byte array starting at offset `off` to this output stream. The general contract for `write(b, off, len)` is that some of the bytes in the array `b` are written to the output stream in order; element `b[off]` is the first byte written and `b[off+len-1]` is the last byte written by this operation. If `b` is `null`, a `NullPointerException` is thrown. If `off` is negative, or `len` is negative, or `off+len` is greater than the length of the array `b`, then an `IndexOutOfBoundsException` is thrown. Annotations @Override Exceptions IOException: if an I/O error occurs. In particular, an `IOException` is thrown if the output stream is closed.

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

Overrides java.io.OutputStream.write.

Doc from java.io.OutputStream.write.

Writes len bytes from the specified byte array starting at offset off to this output stream. The general contract for write(b, off, len) is that some of the bytes in the array b are written to the output stream in order; element b[off] is the first byte written and b[off+len-1] is the last byte written by this operation.

If b is null, a NullPointerException is thrown.

If off is negative, or len is negative, or off+len is greater than the length of the array b, then an IndexOutOfBoundsException is thrown.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs. In particular, an IOException is thrown if the output stream is closed.

public Class NonBlockingPumpInputStream

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class NonBlockingPumpInputStream.NbpOutputStream

Constructor Summary

Method Summary

Constructor Detail

Method Detail