stream: use pipe() to also handle internal streams

stream: use pipe() to also handle internal streams #108