Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Tubes
Synopsis
- type Series i o t a r = CPS r (Tube i o r t) a
- deliver :: Monad t => Series i o t r r -> t r
- yield :: o -> Series i o t () r
- await :: Series i o t i r
- finish :: Monad t => Series i o t () ()
- impact :: Monad t => t a -> Series i o t a ()
- (><) :: forall i e a o t. Monad t => Series i e t () () -> Series e o t () () -> Series i o t a ()
- newtype Tube i o r t a = Tube {}
- newtype Source i t r = Source {}
- newtype Sink o t r = Sink {}
- pause :: (() -> Tube i o r t a) -> Source i t r -> Source o t r
- suspend :: (i -> Tube i o r t a) -> Sink o t r -> Sink i t r
A series of tubes
Construction and evaluation
deliver :: Monad t => Series i o t r r -> t r Source #
"...deliver[s] vast amounts of information" from a Series
of tubes. :)
impact :: Monad t => t a -> Series i o t a () Source #
Embeds a value with side effects into an appropriate Series
.
Combination
(><) :: forall i e a o t. Monad t => Series i e t () () -> Series e o t () () -> Series i o t a () Source #
Utility
The head of a stream processing series.
The reservoir at the end of a stream processing pipeline.