+ pipeline + pipelineAsync impl (port of core.async)
+ pipeline tests