code: def close(self) -> None:
          
          self._close = True
          if self._waiter:
              self._waiter.cancel()
docs: Stop accepting new pipelinig messages and close
          connection when handlers done processing messages