private OutputStream initializeSource ( ) { try { PipedOutputStream pipeOut = new PipedOutputStream ( ) ; PipedInputStream pipeIn = new PipedInputStream ( pipeOut ) ; filterInput_ = pipeIn ; return new FilterSourceStream ( pipeOut ) ; } catch ( Exception e ) { throw new RuntimeException ( "Can't initialize source stream" , e ) ; } }
Initializes the source for filter input .