Module

Pipes.Aff

Package: purescript-pipes-aff
Repository: felixschl/purescript-pipes-aff

#send Source

send :: forall a eff. Output eff a -> a -> Aff eff Boolean

#recv Source

recv :: forall a eff. Input eff a -> Aff eff (Maybe a)

#Output Source

newtype Output eff a

#Input Source

newtype Input eff a

#spawn Source

spawn :: forall eff a. Buffer a -> AffAVar eff { input :: Input (avar :: AVAR | eff) a, output :: Output (avar :: AVAR | eff) a, seal :: AffAVar eff Unit }

#toOutput Source

toOutput :: forall eff m a. MonadAff eff m => Output eff a -> Consumer_ a m Unit

Convert an 'Output' to a 'Pipes.Consumer'

#fromInput Source

fromInput :: forall eff m a. MonadAff eff m => Input eff a -> Producer_ a m Unit

Convert an 'Input' to a 'Pipes.Producer'

#Buffer Source

data Buffer a

#unbounded Source

unbounded :: forall a. Buffer a

Bounded Int Latest a Newest Int Store an unbounded number of messages in a FIFO queue

#new Source

new :: forall a. Buffer a

Store an unbounded number of messages in a FIFO queue

Modules: Pipes.Aff