churros-0.1.6.0: Channel/Arrow based streaming computation library.
Safe HaskellSafe-Inferred
LanguageHaskell2010

Control.Churro.Transport.MVar

Description

MVar Transport Instance. Blocks when item hasn't been consumed downstream.

Synopsis

Documentation

runWaitMVar :: ChurroMVar a Void Void -> IO a Source #

Convenience function for running a Churro with an MVar Transport.

runWaitListMVar :: ChurroMVar () Void o -> IO [o] Source #

Convenience function for running a Churro into a List with an MVar Transport.

Orphan instances

Transport MVar Source # 
Instance details

Associated Types

data In MVar :: Type -> Type Source #

data Out MVar :: Type -> Type Source #

Methods

flex :: IO (In MVar a, Out MVar a) Source #

yank :: Out MVar a -> IO a Source #

yeet :: In MVar a -> a -> IO () Source #