module Streaming.Eversion.Pipes (
pipeEvertible
, evert
, pipeEvertibleM
, evertM
, pipeEvertibleMIO
, evertMIO
, pipeTransvertible
, transvert
, pipeTransvertibleM
, transvertM
, pipeTransvertibleMIO
, transvertMIO
, pipeLeftoversE
, pipeTransE
) where
import Control.Monad.IO.Class
import Control.Monad.Trans.Class
import Control.Monad.Trans.Except
import Streaming(Of(..))
import qualified Streaming.Prelude
import Streaming.Eversion
import Pipes
import Pipes.Prelude
pipeEvertible :: (forall m r. Monad m => Producer a m r -> m (x,r))
-> Evertible a x
pipeEvertible f = evertible (\stream -> fmap (\(x,r) -> x :> r) (f (Pipes.Prelude.unfoldr Streaming.Prelude.next stream)))
pipeEvertibleM :: (forall t r. (MonadTrans t, Monad (t m)) => Producer a (t m) r -> t m (x,r))
-> EvertibleM m a x
pipeEvertibleM f = evertibleM (\stream -> fmap (\(x,r) -> x :> r) (f (Pipes.Prelude.unfoldr Streaming.Prelude.next stream)))
pipeEvertibleMIO :: (forall t r. (MonadTrans t, MonadIO (t m)) => Producer a (t m) r -> t m (x,r))
-> EvertibleMIO m a x
pipeEvertibleMIO f = evertibleMIO (\stream -> fmap (\(x,r) -> x :> r) (f (Pipes.Prelude.unfoldr Streaming.Prelude.next stream)))
pipeTransvertible :: (forall m r. Monad m => Producer a m r -> Producer b m r)
-> Transvertible a b
pipeTransvertible pt = transvertible (\stream -> Streaming.Prelude.unfoldr Pipes.next (pt (Pipes.Prelude.unfoldr Streaming.Prelude.next stream)))
pipeTransvertibleM :: (forall t r. (MonadTrans t, Monad (t m)) => Producer a (t m) r -> Producer b (t m) r)
-> TransvertibleM m a b
pipeTransvertibleM pt = transvertibleM (\stream -> Streaming.Prelude.unfoldr Pipes.next (pt (Pipes.Prelude.unfoldr Streaming.Prelude.next stream)))
pipeTransvertibleMIO :: (forall t r. (MonadTrans t, MonadIO (t m)) => Producer a (t m) r -> Producer b (t m) r)
-> TransvertibleMIO m a b
pipeTransvertibleMIO pt = transvertibleMIO (\stream -> Streaming.Prelude.unfoldr Pipes.next (pt (Pipes.Prelude.unfoldr Streaming.Prelude.next stream)))
pipeLeftoversE :: (MonadTrans t, Monad m, Monad (t (ExceptT bytes m))) => Producer text (t (ExceptT bytes m)) (Producer bytes (t (ExceptT bytes m)) r)
-> Producer text (t (ExceptT bytes m)) r
pipeLeftoversE decodedProducer = decodedProducer >>= \leftoversProducer -> do
leftovers <- lift (next leftoversProducer)
case leftovers of
Left r -> return r
Right (firstleftover,_) -> lift (lift (throwE firstleftover))
pipeTransE :: (MonadTrans t, Monad m, Monad (t (ExceptT e m)))
=> Producer a (t (ExceptT e m)) (Either e r)
-> Producer a (t (ExceptT e m)) r
pipeTransE producer = producer >>= lift . lift . ExceptT . return