Merge into Pipes.Concurrent