concurrent-machines-0.3.0: Concurrent networked stream transducers

Data.Machine.Concurrent.Wye

Description

Support for machines with two inputs from which input may be drawn deterministically or non-deterministically. In contrast to Data.Machine.Wye, the two inputs are eagerly run concurrently in this implementation.

Synopsis

# Documentation

wye :: forall m a a' b b' c. MonadBaseControl IO m => ProcessT m a a' -> ProcessT m b b' -> WyeT m a' b' c -> WyeT m a b c Source #

Precompose a Process onto each input of a Wye (or WyeT).

When the choice of input is free (using the Z input descriptor) the two sources will be interleaved.