streamly-0.7.2: Beautiful Streaming, Concurrent and Reactive Composition

Copyright	(c) 2017 Harendra Kumar
License	BSD3
Maintainer	streamly@composewell.com
Stability	experimental
Portability	GHC
Safe Haskell	None
Language	Haskell2010

Streamly.Internal.Data.Stream.SVar

Description

Synopsis

fromSVar :: (MonadAsync m, IsStream t) => SVar Stream m a -> t m a
fromStreamVar :: MonadAsync m => SVar Stream m a -> Stream m a
fromProducer :: MonadAsync m => SVar Stream m a -> Stream m a
fromConsumer :: MonadAsync m => SVar Stream m a -> m Bool
toSVar :: (IsStream t, MonadAsync m) => SVar Stream m a -> t m a -> m ()
pushToFold :: MonadAsync m => SVar Stream m a -> a -> m Bool

Documentation

fromSVar :: (MonadAsync m, IsStream t) => SVar Stream m a -> t m a Source #

fromStreamVar :: MonadAsync m => SVar Stream m a -> Stream m a Source #

Pull a stream from an SVar.

fromProducer :: MonadAsync m => SVar Stream m a -> Stream m a Source #

Pull a stream from an SVar.

fromConsumer :: MonadAsync m => SVar Stream m a -> m Bool Source #

toSVar :: (IsStream t, MonadAsync m) => SVar Stream m a -> t m a -> m () Source #

Write a stream to an SVar in a non-blocking manner. The stream can then be read back from the SVar using fromSVar.

pushToFold :: MonadAsync m => SVar Stream m a -> a -> m Bool Source #