Safe Haskell	Safe
Language	Haskell2010

Data.Drinkery.Tap

Contents

Tap
Producer
ListT
Sink
End of stream

Synopsis

newtype Tap r s m = Tap {
- unTap :: r -> m (s, Tap r s m)
}
consTap :: (Semigroup r, Applicative m) => s -> Tap r s m -> Tap r s m
orderTap :: Semigroup r => r -> Tap r s m -> Tap r s m
makeTap :: Monad m => m (Tap r s m) -> Tap r s m
transTap :: Functor n => (forall x. m x -> n x) -> Tap r s m -> Tap r s n
repeatTap :: Applicative m => s -> Tap r s m
repeatTapM :: Applicative m => m s -> Tap r s m
repeatTapM' :: Applicative m => m s -> Tap () s m
unfoldrTapM :: Applicative m => (r -> s -> m (a, s)) -> s -> Tap r a m
newtype Joint r m s = Joint {
- unJoint :: Tap r s m
}
newtype Producer r s m a = Producer {
- unProducer :: (a -> Tap r s m) -> Tap r s m
}
yield :: (Semigroup r, Applicative f, Applicative m) => s -> Producer r (f s) m ()
accept :: Monoid r => Producer r s m r
inexhaustible :: Producer r s m x -> Tap r s m
tapProducer :: (Monoid r, Applicative m) => Producer r (Maybe s) m a -> Tap r (Maybe s) m
tapProducer' :: Applicative m => Producer () (Maybe s) m a -> Tap () (Maybe s) m
produce :: (Semigroup r, Applicative m) => s -> Producer r s m ()
newtype ListT r m s = ListT {
- unListT :: forall x. (s -> Tap r x m -> Tap r x m) -> Tap r x m -> Tap r x m
}
sample :: Foldable f => f s -> ListT r m s
inquire :: Monoid r => ListT r m r
tapListT :: (Semigroup r, Applicative m) => ListT r m s -> Tap r (Maybe s) m
tapListT' :: Applicative m => ListT () m s -> Tap () (Maybe s) m
retractListT :: Monad m => ListT () m s -> m ()
consume :: (Monoid r, MonadSink (Tap r s) m) => m s
leftover :: (Semigroup r, MonadSink (Tap r s) m) => s -> m ()
request :: (Semigroup r, MonadSink (Tap r s) m) => r -> m ()
prefetch :: (Monoid r, Semigroup r, MonadSink (Tap r s) m) => m s
eof :: (Applicative m, Alternative f) => Tap r (f a) m

Tap

newtype Tap r s m Source #

Tap m r s is a non-monadic, endless producer of s. It takes a request r.

Constructors

Tap
Fields unTap :: r -> m (s, Tap r s m)

Instances

CloseRequest r => Closable (Tap r s) Source #
Instance details Defined in Data.Drinkery.Tap Methods close :: Monad m => Tap r s m -> m () Source #

consTap :: (Semigroup r, Applicative m) => s -> Tap r s m -> Tap r s m Source #

Prepend a new element, delaying requests.

orderTap :: Semigroup r => r -> Tap r s m -> Tap r s m Source #

Send a request to a Tap.

makeTap :: Monad m => m (Tap r s m) -> Tap r s m Source #

Involve an action.

transTap :: Functor n => (forall x. m x -> n x) -> Tap r s m -> Tap r s n Source #

repeatTap :: Applicative m => s -> Tap r s m Source #

repeatTapM :: Applicative m => m s -> Tap r s m Source #

repeatTapM' :: Applicative m => m s -> Tap () s m Source #

unfoldrTapM :: Applicative m => (r -> s -> m (a, s)) -> s -> Tap r a m Source #

newtype Joint r m s Source #

(<*>) zips two taps.

Constructors

Joint
Fields unJoint :: Tap r s m

Instances

Functor m => Functor (Joint r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods fmap :: (a -> b) -> Joint r m a -> Joint r m b # (<$) :: a -> Joint r m b -> Joint r m a #
Applicative m => Applicative (Joint r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods pure :: a -> Joint r m a # (<>) :: Joint r m (a -> b) -> Joint r m a -> Joint r m b # liftA2 :: (a -> b -> c) -> Joint r m a -> Joint r m b -> Joint r m c # (>) :: Joint r m a -> Joint r m b -> Joint r m b # (<*) :: Joint r m a -> Joint r m b -> Joint r m a #

Producer

newtype Producer r s m a Source #

Monadic producer

Constructors

Producer
Fields unProducer :: (a -> Tap r s m) -> Tap r s m

Instances

MonadState s m => MonadState s (Producer p q m) Source #
Instance details Defined in Data.Drinkery.Tap Methods get :: Producer p q m s # put :: s -> Producer p q m () # state :: (s -> (a, s)) -> Producer p q m a #
MonadReader r m => MonadReader r (Producer p q m) Source #
Instance details Defined in Data.Drinkery.Tap Methods ask :: Producer p q m r # local :: (r -> r) -> Producer p q m a -> Producer p q m a # reader :: (r -> a) -> Producer p q m a #
MonadSink t m => MonadSink t (Producer p q m) Source #
Instance details Defined in Data.Drinkery.Tap Methods receiving :: (forall (n :: * -> *). Monad n => t n -> n (a, t n)) -> Producer p q m a Source #
MonadTrans (Producer r s) Source #
Instance details Defined in Data.Drinkery.Tap Methods lift :: Monad m => m a -> Producer r s m a #
Monad (Producer r s m) Source #
Instance details Defined in Data.Drinkery.Tap Methods (>>=) :: Producer r s m a -> (a -> Producer r s m b) -> Producer r s m b # (>>) :: Producer r s m a -> Producer r s m b -> Producer r s m b # return :: a -> Producer r s m a # fail :: String -> Producer r s m a #
Functor (Producer r s m) Source #
Instance details Defined in Data.Drinkery.Tap Methods fmap :: (a -> b) -> Producer r s m a -> Producer r s m b # (<$) :: a -> Producer r s m b -> Producer r s m a #
Applicative (Producer r s m) Source #
Instance details Defined in Data.Drinkery.Tap Methods pure :: a -> Producer r s m a # (<>) :: Producer r s m (a -> b) -> Producer r s m a -> Producer r s m b # liftA2 :: (a -> b -> c) -> Producer r s m a -> Producer r s m b -> Producer r s m c # (>) :: Producer r s m a -> Producer r s m b -> Producer r s m b # (<*) :: Producer r s m a -> Producer r s m b -> Producer r s m a #
MonadIO m => MonadIO (Producer r s m) Source #
Instance details Defined in Data.Drinkery.Tap Methods liftIO :: IO a -> Producer r s m a #

yield :: (Semigroup r, Applicative f, Applicative m) => s -> Producer r (f s) m () Source #

accept :: Monoid r => Producer r s m r Source #

Accept orders and clear the queue.

inexhaustible :: Producer r s m x -> Tap r s m Source #

Create a infinite Tap from a Producer.

inexhaustible :: Producer r s (Sink tap m) x -> Distiller tap m r s

tapProducer :: (Monoid r, Applicative m) => Producer r (Maybe s) m a -> Tap r (Maybe s) m Source #

Run a Producer action and terminate the stream with eof.

tapProducer' :: Applicative m => Producer () (Maybe s) m a -> Tap () (Maybe s) m Source #

Specialised runProducer

produce :: (Semigroup r, Applicative m) => s -> Producer r s m () Source #

Produce one element. Orders are put off.

ListT

newtype ListT r m s Source #

Backtracking producer a.k.a. "ListT done right".

Constructors

ListT
Fields unListT :: forall x. (s -> Tap r x m -> Tap r x m) -> Tap r x m -> Tap r x m

Instances

MonadState s m => MonadState s (ListT p m) Source #
Instance details Defined in Data.Drinkery.Tap Methods get :: ListT p m s # put :: s -> ListT p m () # state :: (s -> (a, s)) -> ListT p m a #
MonadReader r m => MonadReader r (ListT p m) Source #
Instance details Defined in Data.Drinkery.Tap Methods ask :: ListT p m r # local :: (r -> r) -> ListT p m a -> ListT p m a # reader :: (r -> a) -> ListT p m a #
MonadSink t m => MonadSink t (ListT p m) Source #
Instance details Defined in Data.Drinkery.Tap Methods receiving :: (forall (n :: * -> *). Monad n => t n -> n (a, t n)) -> ListT p m a Source #
MonadTrans (ListT r) Source #
Instance details Defined in Data.Drinkery.Tap Methods lift :: Monad m => m a -> ListT r m a #
Monad (ListT r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods (>>=) :: ListT r m a -> (a -> ListT r m b) -> ListT r m b # (>>) :: ListT r m a -> ListT r m b -> ListT r m b # return :: a -> ListT r m a # fail :: String -> ListT r m a #
Functor (ListT r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods fmap :: (a -> b) -> ListT r m a -> ListT r m b # (<$) :: a -> ListT r m b -> ListT r m a #
Applicative (ListT r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods pure :: a -> ListT r m a # (<>) :: ListT r m (a -> b) -> ListT r m a -> ListT r m b # liftA2 :: (a -> b -> c) -> ListT r m a -> ListT r m b -> ListT r m c # (>) :: ListT r m a -> ListT r m b -> ListT r m b # (<*) :: ListT r m a -> ListT r m b -> ListT r m a #
MonadIO m => MonadIO (ListT r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods liftIO :: IO a -> ListT r m a #
Alternative (ListT r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods empty :: ListT r m a # (<\|>) :: ListT r m a -> ListT r m a -> ListT r m a # some :: ListT r m a -> ListT r m [a] # many :: ListT r m a -> ListT r m [a] #
MonadPlus (ListT r m) Source #
Instance details Defined in Data.Drinkery.Tap Methods mzero :: ListT r m a # mplus :: ListT r m a -> ListT r m a -> ListT r m a #