Moduleasync-2.2.6

Control.Concurrent.Stream

valueforConcurrentlyBounded :: Int -> [a] -> (a -> IO b) -> IO [b]

valuemapConcurrentlyBounded :: Int -> (a -> IO b) -> [a] -> IO [b]

valuestream :: Int -> ((a -> IO ()) -> IO ()) -> (a -> IO ()) -> IO ()

valuestreamBound :: Int -> ((a -> IO ()) -> IO ()) -> (a -> IO ()) -> IO ()

valuestreamWithInput

valuestreamWithInputOutput

valuestreamWithOutput :: Int -> ((a -> IO ()) -> IO ()) -> (a -> IO c) -> IO [c]