Data.Machine.Concurrent.Wye

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.

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

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.