Package aQute.remote.agent

Class RedirectInput

java.lang.Object

java.io.InputStream

aQute.remote.agent.RedirectInput

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

Shell

public class RedirectInput
extends InputStream

An filter stream that takes a string from the supervisor and then provides it as a read to the user of this Input Stream. It also dispatches the text to an original stream.It does not use Piped*Stream because they turned hard to break. This implementation uses a ring buffer.

Constructor Summary

Constructors

Constructor	Description
RedirectInput()	Create a redirector without an original
RedirectInput(InputStream in)	Create a redirector input stream with an original input stream

Method Summary

Modifier and Type	Method	Description
void	add(String s)	Provide the string that should be treated as input for the running code.
void	close()
InputStream	getOrg()	Get the original inputstream, potentially null
int	read()	Read a byte from the input buffer.
int	read(byte[] buffer)
int	read(byte[] buffer, int offset, int length)	And the read for a larger buffer

Methods inherited from class java.io.InputStream

available, mark, markSupported, nullInputStream, 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

RedirectInput

public RedirectInput(InputStream in)
              throws IOException

Create a redirector input stream with an original input stream

Parameters:

in - the original

Throws:

IOException

RedirectInput

public RedirectInput()

Create a redirector without an original

Method Details

getOrg

public InputStream getOrg()

Get the original inputstream, potentially null

Returns:

null or the original input stream

add

public void add(String s)
         throws IOException

Provide the string that should be treated as input for the running code.

Parameters:

s - the string

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

read

public int read()
         throws IOException

Read a byte from the input buffer. We will be fully interruptible, in the case of an interrupt we return -1 (eof)

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] buffer,
 int offset,
 int length)
         throws IOException

And the read for a larger buffer

Overrides:

read in class InputStream

Throws:

IOException

read

public int read(byte[] buffer)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException