Hoogle Search
Within LTS Haskell 24.42 (ghc-9.10.3)
Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.
parMapM :: MonadAsync m => (Config -> Config) -> (a -> m b) -> Stream m a -> Stream m bstreamly Streamly.Internal.Data.Stream.Prelude Definition:
>>> parMapM modifier f = Stream.parConcatMap modifier (Stream.fromEffect . f)
For example, the following finishes in 3 seconds (as opposed to 6 seconds) because all actions run in parallel. Even though results are available out of order they are ordered due to the config option:>>> f x = delay x >> return x >>> Stream.fold Fold.toList $ Stream.parMapM (Stream.ordered True) f $ Stream.fromList [3,2,1] 1 sec 2 sec 3 sec [3,2,1]
concatMapM :: (IsStream t, Monad m) => (a -> m (t m b)) -> t m a -> t m bstreamly Streamly.Prelude Map a stream producing monadic function on each element of the stream and then flatten the results into a single stream. Since the stream generation function is monadic, unlike concatMap, it can produce an effect at the beginning of each iteration of the inner loop.
sPMapMV :: Stream -> MVar PlayMaptidal Sound.Tidal.Boot No documentation available.
sPMapMV :: Stream -> MVar PlayMaptidal Sound.Tidal.Stream.Types No documentation available.
-
A single-entity stateful Map in STM, similar to tmapchan Please see the README on Github at https://git.localcooking.com/tooling/tmapmvar#readme
module Control.Concurrent.STM.
TMapMVar No documentation available.
-
tmapmvar Control.Concurrent.STM.TMapMVar No documentation available.
TMapMVar :: TVar (Map k (TMVar a)) -> TMapMVar k atmapmvar Control.Concurrent.STM.TMapMVar No documentation available.
getTMapMVar :: TMapMVar k a -> TVar (Map k (TMVar a))tmapmvar Control.Concurrent.STM.TMapMVar No documentation available.
newTMapMVar :: STM (TMapMVar k a)tmapmvar Control.Concurrent.STM.TMapMVar No documentation available.