Safe Haskell	None
Language	Haskell2010

Pipes.Fluid.ImpulseIO

Synopsis

newtype ImpulseIO m a = ImpulseIO {
- impulsivelyIO :: Producer a m ()
}
module Pipes.Fluid.Merge

Documentation

newtype ImpulseIO m a #

The applicative instance of this combines multiple Producers reactively ie, yields a value as soon as either or both of the input producers yields a value. This creates two threads each time this combinator is used. Warning: This means that the monadic effects are run in isolation from each other so if the monad is something like (StateT s IO), then the state will alternate between the two input producers, which is most likely not what you want.

Constructors

ImpulseIO
Fields impulsivelyIO :: Producer a m ()

Instances

Monad m => Functor (ImpulseIO m) #
Instance details Defined in Pipes.Fluid.ImpulseIO Methods fmap :: (a -> b) -> ImpulseIO m a -> ImpulseIO m b # (<$) :: a -> ImpulseIO m b -> ImpulseIO m a #
(MonadBaseControl IO m, Forall (Pure m)) => Applicative (ImpulseIO m) #
Instance details Defined in Pipes.Fluid.ImpulseIO Methods pure :: a -> ImpulseIO m a # (<>) :: ImpulseIO m (a -> b) -> ImpulseIO m a -> ImpulseIO m b # liftA2 :: (a -> b -> c) -> ImpulseIO m a -> ImpulseIO m b -> ImpulseIO m c # (>) :: ImpulseIO m a -> ImpulseIO m b -> ImpulseIO m b # (<*) :: ImpulseIO m a -> ImpulseIO m b -> ImpulseIO m a #
(MonadBaseControl IO m, Forall (Pure m)) => Merge (ImpulseIO m) #	Reactively combines two producers, given initial values to use when the produce hasn't produced anything yet Combine two signals, and returns a signal that emits `Either bothfired (Either (leftFired, previousRight) (previousLeft, rightFired))`. This creates two threads each time this combinator is used. Warning: This means that the monadic effects are run in isolation from each other so if the monad is something like (StateT s IO), then the state will alternate between the two input producers, which is most likely not what you want. This will be detect as a compile error due to use of Control.Concurrent.Async.Lifted.Safe
Instance details Defined in Pipes.Fluid.ImpulseIO Methods merge' :: Maybe x -> Maybe y -> ImpulseIO m x -> ImpulseIO m y -> ImpulseIO m (Merged x y) #
(MonadBaseControl IO m, Forall (Pure m), Semigroup a) => Semigroup (ImpulseIO m a) #
Instance details Defined in Pipes.Fluid.ImpulseIO Methods (<>) :: ImpulseIO m a -> ImpulseIO m a -> ImpulseIO m a # sconcat :: NonEmpty (ImpulseIO m a) -> ImpulseIO m a # stimes :: Integral b => b -> ImpulseIO m a -> ImpulseIO m a #
(MonadBaseControl IO m, Forall (Pure m), Semigroup a) => Monoid (ImpulseIO m a) #
Instance details Defined in Pipes.Fluid.ImpulseIO Methods mempty :: ImpulseIO m a # mappend :: ImpulseIO m a -> ImpulseIO m a -> ImpulseIO m a # mconcat :: [ImpulseIO m a] -> ImpulseIO m a #
Wrapped (ImpulseIO m a) #
Instance details Defined in Pipes.Fluid.ImpulseIO Associated Types type Unwrapped (ImpulseIO m a) :: * # Methods _Wrapped' :: Iso' (ImpulseIO m a) (Unwrapped (ImpulseIO m a)) #
ImpulseIO m1 a1 ~ t => Rewrapped (ImpulseIO m2 a2) t #
Instance details Defined in Pipes.Fluid.ImpulseIO
type Unwrapped (ImpulseIO m a) #
Instance details Defined in Pipes.Fluid.ImpulseIO type Unwrapped (ImpulseIO m a) = Producer a m ()

module Pipes.Fluid.Merge