Data.Drinkery.Tap

Tap

newtype Tap r s m

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)

Methods

close :: Monad m => Tap r s m -> m ()

consTap :: (Monoid r, Applicative m) => s -> Tap r s m -> Tap r s m

Prepend a new element, delaying requests.

orderTap :: Monoid r => r -> Tap r s m -> Tap r s m

Send a request to a Tap.

makeTap :: (Monoid r, Monad m) => m (Tap r s m) -> Tap r s m

Involve an action.

Barman

newtype Barman r s m a

Monadic producer

Constructors

Barman

Fields

• unBarman :: (a -> Tap r s m) -> Tap r s m

Instances

MonadDrunk t m => MonadDrunk t (Barman p q m)

Methods

drinking :: (forall (n :: * -> *). Monad n => t n -> n (a, t n)) -> Barman p q m a

MonadTrans (Barman r s)

Methods

lift :: Monad m => m a -> Barman r s m a

Monad (Barman r s m)

Methods

(>>=) :: Barman r s m a -> (a -> Barman r s m b) -> Barman r s m b

(>>) :: Barman r s m a -> Barman r s m b -> Barman r s m b

return :: a -> Barman r s m a

fail :: String -> Barman r s m a

Functor (Barman r s m)

Methods

fmap :: (a -> b) -> Barman r s m a -> Barman r s m b

(<$) :: a -> Barman r s m b -> Barman r s m a

Applicative (Barman r s m)

Methods

pure :: a -> Barman r s m a

(<*>) :: Barman r s m (a -> b) -> Barman r s m a -> Barman r s m b

liftA2 :: (a -> b -> c) -> Barman r s m a -> Barman r s m b -> Barman r s m c

(*>) :: Barman r s m a -> Barman r s m b -> Barman r s m b

(<*) :: Barman r s m a -> Barman r s m b -> Barman r s m a

yield :: (Monoid r, Applicative m) => s -> Barman r s m ()

Produce one element. Orders are put off.

accept :: Monoid r => Barman r s m r

Accept orders and clear the queue.

inexhaustible :: Barman r s m x -> Tap r s m

Create a infinite Tap from a Barman.

inexhaustible :: Barman r s (Drinker tap m) x -> Distiller tap m r s

runBarman :: (Monoid r, Applicative m, Alternative f) => Barman r (f s) m a -> Tap r (f s) m

Run a Barman action and terminate the stream with eof.

runBarman' :: (Applicative m, Alternative f) => Barman () (f s) m a -> Tap () (f s) m

Specialised runBarman

pour :: (Monoid r, Applicative f, Applicative m) => s -> Barman r (f s) m ()

Sommelier

newtype Sommelier r m s

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

Constructors

Sommelier

Fields

• unSommelier :: forall x. (s -> Tap r x m -> Tap r x m) -> Tap r x m -> Tap r x m

Instances

MonadDrunk t m => MonadDrunk t (Sommelier p m)

Methods

drinking :: (forall (n :: * -> *). Monad n => t n -> n (a, t n)) -> Sommelier p m a

MonadTrans (Sommelier r)

Methods

lift :: Monad m => m a -> Sommelier r m a

Monad (Sommelier r m)

Methods

(>>=) :: Sommelier r m a -> (a -> Sommelier r m b) -> Sommelier r m b

(>>) :: Sommelier r m a -> Sommelier r m b -> Sommelier r m b

return :: a -> Sommelier r m a

fail :: String -> Sommelier r m a

Functor (Sommelier r m)

Methods

fmap :: (a -> b) -> Sommelier r m a -> Sommelier r m b

(<$) :: a -> Sommelier r m b -> Sommelier r m a

Applicative (Sommelier r m)

Methods

pure :: a -> Sommelier r m a

(<*>) :: Sommelier r m (a -> b) -> Sommelier r m a -> Sommelier r m b

liftA2 :: (a -> b -> c) -> Sommelier r m a -> Sommelier r m b -> Sommelier r m c

(*>) :: Sommelier r m a -> Sommelier r m b -> Sommelier r m b

(<*) :: Sommelier r m a -> Sommelier r m b -> Sommelier r m a

MonadIO m => MonadIO (Sommelier r m)

Methods

liftIO :: IO a -> Sommelier r m a

Alternative (Sommelier r m)

Methods

empty :: Sommelier r m a

(<|>) :: Sommelier r m a -> Sommelier r m a -> Sommelier r m a

some :: Sommelier r m a -> Sommelier r m [a]

many :: Sommelier r m a -> Sommelier r m [a]

MonadPlus (Sommelier r m)

Methods

mzero :: Sommelier r m a

mplus :: Sommelier r m a -> Sommelier r m a -> Sommelier r m a

taste :: Foldable f => f s -> Sommelier r m s

Take all the elements in a Foldable container.

inquire :: Monoid r => Sommelier r m r

Get a request.

runSommelier :: (Monoid r, Applicative m, Alternative f) => Sommelier r m s -> Tap r (f s) m

Run Sommelier and terminate the stream with eof.

runSommelier' :: (Applicative m, Alternative f) => Sommelier () m s -> Tap () (f s) m

Specialised runSommelier

Drinker

drink :: (Monoid r, MonadDrunk (Tap r s) m) => m s

leftover :: (Monoid r, MonadDrunk (Tap r s) m) => s -> m ()

request :: (Monoid r, MonadDrunk (Tap r s) m) => r -> m ()

smell :: (Monoid r, MonadDrunk (Tap r s) m) => m s

Get one element without consuming.

End of stream

eof :: (Applicative m, Alternative f) => Tap r (f a) m

End of stream