Change runSink to runDownstream