SDR.PipeUtils

Pipes utility functions

Documentation

fork :: Monad m => Producer a m r -> Producer a (Producer a m) r

Fork a pipe

combine :: Monad m => Consumer a m r -> Consumer a m r -> Consumer a m r

Combine two consumers into a single consumer

printStream :: Show a => Int -> Consumer a IO ()

A consumer that prints everything to stdout

devnull :: Monad m => Consumer a m ()

A consumer that discards everything

rate :: Int -> Pipe a a IO b

Passthrough pipe that prints the sample rate

pMapAccum

Arguments

:: Monad m

=> (acc -> x -> (acc, y))

Accumulating function

-> acc

Initial value of the accumulator

-> Pipe x y m ()

mapAccum for Pipes