-- Hoogle documentation, generated by Haddock -- See Hoogle, http://www.haskell.org/hoogle/ -- | Effectful streaming library based on shortcut fusion techniques -- -- Effectful streaming library based on shortcut fusion techniques @package fusion @version 0.1.2 module Fusion -- | A simple stepper, as suggested by Duncan Coutts in his Thesis paper, -- "Stream Fusion: Practical shortcut fusion for coinductive sequence -- types". This version adds a result type. data Step s a r Done :: r -> Step s a r Skip :: s -> Step s a r Yield :: s -> a -> Step s a r newtype StepList s r a StepList :: Step s a r -> StepList s r a [getStepList] :: StepList s r a -> Step s a r data Stream a m r Stream :: (s -> m (Step s a r)) -> s -> Stream a m r -- | Map over the values produced by a stream. -- --
--   >>> mapS (+1) (fromList [1..3]) :: Stream Int Identity ()
--   Stream [2,3,4]
--   
mapS :: Functor m => (a -> b) -> Stream a m r -> Stream b m r filterS :: Functor m => (a -> Bool) -> Stream a m r -> Stream a m r dropS :: Monad m => Int -> Stream a m r -> Stream a m () concatS :: Monad m => Stream (Stream a m r) m r -> Stream a m r fromList :: Foldable f => Applicative m => f a -> Stream a m () fromListM :: (Monad m, Foldable f) => m (f a) -> Stream a m () toListS :: Monad m => Stream a m r -> m [a] lazyToListS :: Stream a IO r -> IO [a] runStream :: Monad m => Stream a m r -> m r runStream_ :: Monad m => Stream Void m r -> m r emptyStream :: (Monad m, Applicative m) => Stream Void m () bracketS :: (Monad m, MonadMask (Base m), MonadSafe m) => Base m s -> (s -> Base m ()) -> (forall r. s -> (s -> a -> m r) -> (s -> m r) -> m r -> m r) -> Stream a m () next :: Monad m => Stream a m r -> m (Either r (a, Stream a m r)) newtype ListT m a ListT :: Stream a m () -> ListT m a [getListT] :: ListT m a -> Stream a m () concatL :: (Monad m, Applicative m) => ListT m (ListT m a) -> ListT m a type Producer b m r = Stream b m r type Pipe a b m r = Stream a m () -> Stream b m r type Consumer a m r = Stream a m () -> m r each :: (Applicative m, Foldable f) => f a -> Producer a m () mapP :: (Monad m, Applicative m) => (a -> b) -> Pipe a b m () instance GHC.Base.Functor (Fusion.Step s a) instance GHC.Base.Functor (Fusion.StepList s r) instance GHC.Show.Show a => GHC.Show.Show (Fusion.Stream a Data.Functor.Identity.Identity r) instance GHC.Base.Functor m => GHC.Base.Functor (Fusion.Stream a m) instance (GHC.Base.Monad m, GHC.Base.Applicative m) => GHC.Base.Applicative (Fusion.Stream a m) instance Control.Monad.Trans.Class.MonadTrans (Fusion.Stream a) instance GHC.Base.Functor m => GHC.Base.Functor (Fusion.ListT m) instance (GHC.Base.Monad m, GHC.Base.Applicative m) => GHC.Base.Applicative (Fusion.ListT m) instance (GHC.Base.Monad m, GHC.Base.Applicative m) => GHC.Base.Monad (Fusion.ListT m)