aQute.remote.agent

Class RedirectInput

java.lang.Object

java.io.InputStream

aQute.remote.agent.RedirectInput

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

Shell

public class RedirectInput
extends java.io.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 and Description
RedirectInput() Create a redirector without an original
RedirectInput(java.io.InputStream in) Create a redirector input stream with an original input stream

Method Summary

Methods

Modifier and Type	Method and Description
void	add(java.lang.String s) Provide the string that should be treated as input for the running code.
void	close()
java.io.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, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

RedirectInput

public RedirectInput(java.io.InputStream in)
              throws java.io.IOException

Create a redirector input stream with an original input stream

Parameters:

in - the original

Throws:

java.io.IOException

RedirectInput

public RedirectInput()

Create a redirector without an original

Method Detail

getOrg

public java.io.InputStream getOrg()

Get the original inputstream, potentially null

Returns:

null or the original input stream

add

public void add(java.lang.String s)
         throws java.io.IOException

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

Parameters:

s - the string

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream

read

public int read()
         throws java.io.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 java.io.InputStream

Throws:

java.io.IOException

read

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

And the read for a larger buffer

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] buffer)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException