provides `AsyncPipeline`, a deadlock-free replacement for buffered streams - View it on GitHub