Data.MonadicStreamFunction.Util

Contents

• Useful aliases
• Stateful accumulation
  • Accumulation for monoids
  • Accumulation for VectorSpace instances
• Generating Signals
• Special cases of map
• Adding side effects
• Debugging
• Inserting monadic actions into MSFs
• Lifting from one monad into another
• Delays and signal overwriting
• Alternative running functions

Synopsis

• type MStream m a = MSF m () a
• type MSink m a = MSF m a ()
• accumulateWith :: Monad m => (a -> s -> s) -> s -> MSF m a s
• mappendS :: (Monoid n, Monad m) => MSF m n n
• mappendFrom :: (Monoid n, Monad m) => n -> MSF m n n
• sumFrom :: (RModule v, Monad m) => v -> MSF m v v
• sumS :: (RModule v, Monad m) => MSF m v v
• count :: (Num n, Monad m) => MSF m a n
• unfold :: Monad m => (a -> (b, a)) -> a -> MSF m () b
• repeatedly :: Monad m => (a -> a) -> a -> MSF m () a
• mapMSF :: Monad m => MSF m a b -> MSF m [a] [b]
• mapMaybeS :: Monad m => MSF m a b -> MSF m (Maybe a) (Maybe b)
• withSideEffect :: Monad m => (a -> m b) -> MSF m a a
• withSideEffect_ :: Monad m => m b -> MSF m a a
• traceWith :: (Monad m, Show a) => (String -> m ()) -> String -> MSF m a a
• trace :: Show a => String -> MSF IO a a
• traceWhen :: (Monad m, Show a) => (a -> Bool) -> (String -> m ()) -> String -> MSF m a a
• pauseOn :: Show a => (a -> Bool) -> String -> MSF IO a a
• insert :: Monad m => MSF m (m a) a
• arrM_ :: Monad m => m b -> MSF m a b
• (^>>>) :: MonadBase m1 m2 => MSF m1 a b -> MSF m2 b c -> MSF m2 a c
• (>>>^) :: MonadBase m1 m2 => MSF m2 a b -> MSF m1 b c -> MSF m2 a c
• iPost :: Monad m => b -> MSF m a b -> MSF m a b
• next :: Monad m => b -> MSF m a b -> MSF m a b
• embed_ :: (Functor m, Monad m) => MSF m a () -> [a] -> m ()

Useful aliases

Stateful accumulation

Accumulation for monoids

Accumulation for VectorSpace instances

Generating Signals

Special cases of map

Adding side effects

Debugging

Inserting monadic actions into MSFs

Lifting from one monad into another

Delays and signal overwriting

Alternative running functions