flyd-mergeall

mergeAll implementation for flyd streams