def request(self, method, path, body=None, headers=None):
        self.path = path
        self.method = method
        if body is not None:
            try:
                read = body.read
            except __HOLE__:
                self.body = body
            else:
                self.body = read()
        if headers is not None:
            self.headers.extend(list(items(headers)))
dataset/ETHPy150Open celery/kombu/kombu/async/aws/connection.py/AsyncHTTPConnection.request