move 'upstreamPipes' and 'localizedFlow' to RichPipe