Data.Machine.Concurrent.Wye