Piping through to a new stream

First of all, awesome library you have built!

I'm trying to wrap my head around a few things, and currently looking at being able to setup a stream, and then pipe the data from the stream into another (which may go through X number of other streams).

These streams would further filter, or do some magic, run some async code etc.

What's the best way to do this?

The issue names no files, tests, or entry points. Start by reviewing Highland's existing stream and pipe documentation and API examples, then determine whether the requested chaining and asynchronous processing are already supported. Done would require a clearly defined behavior and an agreed implementation or documentation scope.

Written by the indexing model from the issue text.