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 :: Monad m => (acc -> x -> (acc, y)) -> acc -> Pipe x y m ()