| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Box.Stream
Description
Streaming functionality
Synopsis
- toStream :: MonadConc m => Emitter (STM m) a -> Stream (Of a) m ()
- fromStream :: MonadConc m => Stream (Of b) m () -> Committer (STM m) b -> m ()
- toCommit :: MonadConc m => (Stream (Of a) m () -> m r) -> Cont m (Committer (STM m) a)
- toCommitFold :: MonadConc m => FoldM m a () -> Cont m (Committer (STM m) a)
- toCommitSink :: MonadConc m => (a -> m ()) -> Cont m (Committer (STM m) a)
- toEmit :: MonadConc m => Stream (Of a) m () -> Cont m (Emitter (STM m) a)
- queueStream :: MonadConc m => Stream (Of a) m () -> Cont m (Stream (Of a) m ())
- toStreamM :: MonadConc m => Emitter m a -> Stream (Of a) m ()
- fromStreamM :: MonadConc m => Stream (Of b) m () -> Committer m b -> m ()
Documentation
toStream :: MonadConc m => Emitter (STM m) a -> Stream (Of a) m () Source #
turn an emitter into a stream
fromStream :: MonadConc m => Stream (Of b) m () -> Committer (STM m) b -> m () Source #
turn a stream into a committer
toCommit :: MonadConc m => (Stream (Of a) m () -> m r) -> Cont m (Committer (STM m) a) Source #
create a committer from a stream consumer
toCommitFold :: MonadConc m => FoldM m a () -> Cont m (Committer (STM m) a) Source #
create a committer from a fold
toCommitSink :: MonadConc m => (a -> m ()) -> Cont m (Committer (STM m) a) Source #
create a committer from a sink
toEmit :: MonadConc m => Stream (Of a) m () -> Cont m (Emitter (STM m) a) Source #
create an emitter from a stream