code: def pipeline(self, consumer):
          
          if self._pipeline is None:
              self._pipeline = ResponsePipeline(self)
              self.event('connection_lost').bind(self._close_pipeline)
          self._pipeline.put(consumer)
docs: Add a consumer to the pipeline