Source.divide

[TomasMikula]

def divide[A]: Source[A] -⚬ (Source[A] |*| Source[A])

Forwards incoming element to whichever output polls first.

Biased and unbiased version.

Also, a version that divides elements equally between outputs, regardless of the demand.