Update for _.streams.processing and _.cluster.pipeTo