/** The input stream to read from. */
private PipedInputStream pipedInputStream = new PipedInputStream();
/** The input stream to read from. */
private PipedInputStream pipedInputStream = new PipedInputStream();
public void connect(Source source) throws ConnectException {
Preconditions.checkNotNull(source, "source must not be null");
public void connect(Source source) throws ConnectException {
Preconditions.checkNotNull(source, "source must not be null");