Version 0.5

Author: lovelydinosaur

requests_async/__init__.py

@@ -16,4 +16,4 @@
 from .sessions import Session
 from .status_codes import codes
 
-__version__ = "0.4.1"
+__version__ = "0.5.0"

requests_async/adapters.py

@@ -50,7 +50,7 @@ async def send(
                 method,
                 url,
                 headers=headers,
-                body=body,
+                data=body,
                 stream=stream,
                 ssl=ssl,
                 timeout=timeout,
@@ -83,15 +83,15 @@ def build_response(self, req, resp):
 
         # Make headers case-insensitive.
         response.headers = requests.structures.CaseInsensitiveDict(
-            [(k.decode("latin1"), v.decode("latin1")) for k, v in resp.headers]
+            [(k.decode("latin1"), v.decode("latin1")) for k, v in resp.headers.raw]
         )
 
         # Set encoding.
         response.encoding = requests.utils.get_encoding_from_headers(response.headers)
-        response.reason = resp.reason
+        response.reason = resp.reason_phrase
 
         if resp.is_closed:
-            response._content = resp.body
+            response._content = resp.content
             response._content_consumed = True
         else:
             response._content = False

requests_async/asgi.py

@@ -138,7 +138,7 @@ async def send(message) -> None:
                 body = message.get("body", b"")
                 more_body = message.get("more_body", False)
                 if request.method != "HEAD":
-                    raw_kwargs["body"] += body
+                    raw_kwargs["content"] += body
                 if not more_body:
                     response_complete = True
             elif message["type"] == "http.response.template":
@@ -148,7 +148,7 @@ async def send(message) -> None:
         request_complete = False
         response_started = False
         response_complete = False
-        raw_kwargs = {"body": b""}  # type: typing.Dict[str, typing.Any]
+        raw_kwargs = {"content": b""}  # type: typing.Dict[str, typing.Any]
         template = None
         context = None
 

requests_async/cookies.py

@@ -10,7 +10,7 @@ def extract_cookies_to_jar(jar, request, response):
     :param response: httpcore.Response object
     """
     msg = HTTPMessage()
-    for k, v in response.headers:
+    for k, v in response.headers.raw:
         msg.add_header(k.decode(), v.decode())
 
     # the _original_response field is the wrapped httplib.HTTPResponse object,