Added pipeline protocol

Upstream have merged fanin and fanout into a single pipeline protocol.
Fixes #3.