TomasMikula / libretto

Declarative concurrency and stream processing library for Scala
Mozilla Public License 2.0
196 stars 7 forks source link

unbiased merge #22

Open TomasMikula opened 4 years ago

TomasMikula commented 4 years ago

ValSource.merge favors the first input, which is a consequence of biased race. Implement an unbiased variant where arguments to race are swapped after each step.