streamly-0.7.1: Beautiful Streaming, Concurrent and Reactive Composition

Copyright(c) 2017 Harendra Kumar
LicenseBSD3
Maintainerstreamly@composewell.com
Stabilityexperimental
PortabilityGHC
Safe HaskellNone
LanguageHaskell2010

Streamly.Internal.Data.Stream.SVar

Description

 
Synopsis

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.

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 #