An asynchronous pipe implementation for the Task Parallel Library - View it on GitHub