Data.SouSiT.Source

Documentation

class Source src where

Something that produces data to be processed by a sink

Methods

transfer :: Monad m => src m a -> Sink a m r -> m r

Instances

Source FeedSource

Source SimpleSource

data SimpleSource m a

A basic instance of Source

Constructors

SimpleSource (forall r. Sink a m r -> m r)

Instances

Source SimpleSource

data FeedSource m a

A basic instance of FeedSource (and Source)

Constructors

FeedSource

Fields

feedToSink :: forall r. Sink a m r -> m (Sink a m r)

Instances

Source FeedSource

($$) :: (Source src, Monad m) => src m a -> Sink a m r -> m r

Transfer the data from the source into the sink

utility functions

concatSources :: (Source src2, Monad m) => FeedSource m a -> src2 m a -> SimpleSource m a

Concatenates two sources.

concatSources' :: Monad m => FeedSource m a -> FeedSource m a -> FeedSource m a

Concatenates two sources yielding a FeedSource.

(=+=) :: Monad m => FeedSource m a -> FeedSource m a -> FeedSource m a

Concatenates two sources.

(=+|=) :: (Source src2, Monad m) => FeedSource m a -> src2 m a -> SimpleSource m a

Concatenates two sources.

source construction

actionSource :: Monad m => m (Maybe i) -> FeedSource m i

Source that executes a monadic action to get its inputs. Terminates when the sink terminates or the action returns Nothing.

bracketActionSource :: IO a -> (a -> IO ()) -> (a -> IO (Maybe i)) -> FeedSource IO i

Source that first opens a resource, then transfers itself to the sink and the closes the resource again (in a bracket).