Pipes.Concurrent.PQueue

spawn

withSpawn

Re-exports from Pipes.Concurrent

data Input a

data Output a

fromInput

toOutput