{Merge L1 L2 L3}
:
input streams L1
,L2
-
output stream L3
-
we want a fair merge... not {Append L1 L2 L3}
Solution:
P
connected to L3
L1
(resp
L2
) and forwards to P
proc {Merge L1 L2 L3} P = {NewPort L3} in {Forward L1 P} {Forward L2 P} endfairness of
Merge
guaranteed by fairness of thread scheduling