Safe Haskell | None |
---|---|
Language | Haskell2010 |
Documentation
withTBMChan :: MonadIO m => MonadBaseControl IO m => Int -> (TBMChan a -> m b) -> m b Source #
mergeSourcesWith :: MonadResource m => TMVar Int -> TBMChan a -> (ConduitT () a m () -> IO (StM m ())) -> [ConduitT () a m ()] -> ConduitT () a m () Source #
mergeSources :: MonadResource m => MonadBaseControl IO m => Int -> [ConduitT () a m ()] -> ConduitT () a m () Source #
withSourcesInChanAs :: MonadIO m => MonadBaseControl IO m => (ConduitT () a m () -> m b) -> [ConduitT () a m ()] -> TBMChan a -> m b Source #
withSourcesInChan :: MonadIO m => MonadBaseControl IO m => ConduitT a Void m b -> [ConduitT () a m ()] -> TBMChan a -> m b Source #
withMergedSourcesAs :: MonadIO m => MonadBaseControl IO m => (ConduitT () a m () -> m b) -> Int -> [ConduitT () a m ()] -> m b Source #
withMergedSources :: MonadIO m => MonadBaseControl IO m => ConduitT a Void m b -> Int -> [ConduitT () a m ()] -> m b Source #