Implement pipe to accept incoming stream of data and provide it to second application for processing.