Fixed flow.serial(). It can read from Async upstreams now
Fixed flow.parallel(), can read from async sources now.