Module

Pipes.Aff

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

#seal Source

seal :: forall eff a. Channel a -> Aff (avar :: AVAR | eff) Unit

#Channel Source

data Channel a

#Input Source

newtype Input a

#Output Source

newtype Output a

#input Source

input :: forall a. Channel a -> Input a

#output Source

output :: forall a. Channel a -> Output a

#split Source

split :: forall a. Channel a -> Tuple (Input a) (Output a)

#spawn Source

spawn :: forall eff a. Buffer a -> Aff (avar :: AVAR | eff) (Channel a)

#send Source

send :: forall a eff. a -> Channel a -> Aff (avar :: AVAR | eff) Boolean

#send' Source

send' :: forall a eff. a -> Output a -> Aff (avar :: AVAR | eff) Boolean

#recv Source

recv :: forall a eff. Channel a -> Aff (avar :: AVAR | eff) (Maybe a)

#recv' Source

recv' :: forall a eff. Input a -> Aff (avar :: AVAR | eff) (Maybe a)

#toOutput Source

toOutput :: forall eff m a. MonadAff (avar :: AVAR | eff) m => Channel a -> Consumer_ a m Unit

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

#toOutput' Source

toOutput' :: forall eff m a. MonadAff (avar :: AVAR | eff) m => Output a -> Consumer_ a m Unit

#fromInput Source

fromInput :: forall eff m a. MonadAff (avar :: AVAR | eff) m => Channel a -> Producer_ a m Unit

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

#fromInput' Source

fromInput' :: forall eff m a. MonadAff (avar :: AVAR | eff) m => Input a -> Producer_ a m Unit

#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