com.github.geko444.im4java.process

Class Pipe

java.lang.Object

com.github.geko444.im4java.process.Pipe

All Implemented Interfaces:

ErrorConsumer, InputProvider, OutputConsumer

public class Pipe
extends Object
implements InputProvider, OutputConsumer, ErrorConsumer

This class implements a pipe. Useful for piping input to a process or piping output/error from a process to other streams.

You can use the same Pipe-object for both ends of a process-pipeline. But you cannot use the same Pipe-object as an OutputConsumer and ErrorConsumer at the same time.

Since:

0.95

Version:

$Revision: 1.8 $

Author:

$Author: bablokb $

Field Summary

Fields

Modifier and Type	Field and Description
static int	BUFFER_SIZE Default buffer size of the pipe.

Constructor Summary

Constructors

Constructor and Description
Pipe(InputStream pSource, OutputStream pSink) Constructor.

Method Summary

Modifier and Type	Method and Description
void	consumeError(InputStream pInputStream) The ErrorConsumer must read the error of a process from the given InputStream.
void	consumeOutput(InputStream pInputStream) The OutputConsumer must read the output of a process from the given InputStream.
void	provideInput(OutputStream pOutputStream) The InputProvider must write the input to the given OutputStream.

Methods inherited from class java.lang.Object

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

Field Detail

BUFFER_SIZE

public static final int BUFFER_SIZE

Default buffer size of the pipe. Currently 64KB.

See Also:

Constant Field Values

Constructor Detail

Pipe

public Pipe(InputStream pSource,
            OutputStream pSink)

Constructor. At least one of the arguments should not be null.

Method Detail

provideInput

public void provideInput(OutputStream pOutputStream)
                  throws IOException

The InputProvider must write the input to the given OutputStream.

Specified by:

provideInput in interface InputProvider

Throws:

IOException

consumeOutput

public void consumeOutput(InputStream pInputStream)
                   throws IOException

The OutputConsumer must read the output of a process from the given InputStream.

Specified by:

consumeOutput in interface OutputConsumer

Throws:

IOException

consumeError

public void consumeError(InputStream pInputStream)
                  throws IOException

The ErrorConsumer must read the error of a process from the given InputStream.

Specified by:

consumeError in interface ErrorConsumer

Throws:

IOException