refactor/clean-up IStream.
add/integrate PipeIStream.