-- Hoogle documentation, generated by Haddock -- See Hoogle, http://www.haskell.org/hoogle/ -- | simple pipeline library like conduit -- -- examples/upperFile.hs -- --
-- import Data.Pipe -- import Data.Char -- import System.IO -- import "monads-tf" Control.Monad.Trans -- -- main :: IO () -- main = do -- _ <- runPipe $ readFileP "sample.txt" -- =$= takeP 3 -- =$= convert (map toUpper) -- =$= writeString -- return () -- -- readFileP :: FilePath -> Pipe () String IO () -- readFileP fp = bracket (openFile fp ReadMode) hClose hRead -- -- hRead :: Handle -> Pipe () String IO () -- hRead h = do -- eof <- lift $ hIsEOF h -- if eof then return () else do -- l <- lift $ hGetLine h -- yield l -- hRead h -- -- writeString :: Pipe String () IO () -- writeString = do -- ms <- await -- case ms of -- Just s -> lift (putStrLn s) >> writeString -- _ -> return () -- -- convert :: Monad m => (a -> b) -> Pipe a b m () -- convert f = do -- mx <- await -- case mx of -- Just x -> yield (f x) >> convert f -- _ -> return () -- -- takeP :: Monad m => Int -> Pipe a a m () -- takeP 0 = return () -- takeP n = do -- mx <- await -- case mx of -- Just x -> yield x >> takeP (n - 1) -- _ -> return () --@package simple-pipe @version 0.0.0.6 module Data.Pipe class PipeClass p where p finalize f = p `onBreak` f `onDone` f runPipe :: (PipeClass p, Monad m) => p i o m r -> m (Maybe r) (=$=) :: (PipeClass p, Monad m) => p a b m x -> p b c m y -> p a c m y yield :: (PipeClass p, Monad m) => o -> p i o m () await :: (PipeClass p, Monad m) => p i o m (Maybe i) onBreak :: (PipeClass p, Monad m) => p i o m r -> m b -> p i o m r onDone :: (PipeClass p, Monad m) => p i o m r -> m b -> p i o m r finalize :: (PipeClass p, Monad m) => p i o m r -> m b -> p i o m r mapMonad :: (PipeClass p, Monad m) => (forall a. m a -> m a) -> p i o m r -> p i o m r data Pipe i o m r finally :: (MonadBaseControl IO m, PipeClass p) => p i o m r -> m b -> p i o m r bracket :: (MonadBaseControl IO m, PipeClass p, MonadTrans (p i o), Monad (p i o m)) => m a -> (a -> m b) -> (a -> p i o m r) -> p i o m r instance MonadIO m => MonadIO (Pipe i o m) instance MonadTrans (Pipe i o) instance Monad m => Applicative (Pipe i o m) instance Monad m => Functor (Pipe i o m) instance Monad m => Monad (Pipe i o m) instance PipeClass Pipe module Data.Pipe.List fromList :: (Monad m, Monad (p () a m), PipeClass p) => [a] -> p () a m () -- | Consume all values from the stream and return as a list. This will -- pull all values into memory. toList :: (Monad m, Monad (p a () m), PipeClass p) => p a () m [a]