because primus substreams don't have pipes :( - View it on GitHub