Control.Concurrent.SCC.Streams

Sink and Source types

data Sink m a x

data Source m a x

type SinkFunctor a x

type SourceFunctor a x

class AncestorFunctor a d

Sink and Source constructors

Operations on sinks and sources

Singleton operations

Lifting functions

Bulk operations

Fetching and moving data

type Reader x py y

data Reading x py y

data ReadingResult x py y

Stream transformations

concatMapStream

mapStreamChunks

mapAccumStreamChunks

concatMapAccumStream

partitionStream

Monadic stream transformations

mapMStreamChunks_

unmapMStreamChunks_

parZipWithMStream