RuntimeError when AsyncClient.put has binary request body.

[lee-cq]

When I wish to upload data using AsyncClient.put, it triggers an error telling me this is a synchronous request.

Demo

import asyncio

from httpx import AsyncClient

client = AsyncClient(base_url="https://google.com", timeout=10)


async def run():
    a = await client.put(
        "/api/fs/put",
        content=open(__file__, "rb")
    )
    print(a.json())

asyncio.run(run())

Error Info:

Traceback (most recent call last):
  File "/tmp/t1.py", line 15, in <module>
    asyncio.run(run())
  File "/usr/local/python/3.10.8/lib/python3.10/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/usr/local/python/3.10.8/lib/python3.10/asyncio/base_events.py", line 649, in run_until_complete
    return future.result()
  File "/tmp/t1.py", line 9, in run
    a = await client.put(
  File "/usr/local/python/3.10.8/lib/python3.10/site-packages/httpx/_client.py", line 1885, in put
    return await self.request(
  File "/usr/local/python/3.10.8/lib/python3.10/site-packages/httpx/_client.py", line 1530, in request
    return await self.send(request, auth=auth, follow_redirects=follow_redirects)
  File "/usr/local/python/3.10.8/lib/python3.10/site-packages/httpx/_client.py", line 1617, in send
    response = await self._send_handling_auth(
  File "/usr/local/python/3.10.8/lib/python3.10/site-packages/httpx/_client.py", line 1645, in _send_handling_auth
    response = await self._send_handling_redirects(
  File "/usr/local/python/3.10.8/lib/python3.10/site-packages/httpx/_client.py", line 1682, in _send_handling_redirects
    response = await self._send_single_request(request)
  File "/usr/local/python/3.10.8/lib/python3.10/site-packages/httpx/_client.py", line 1714, in _send_single_request
    raise RuntimeError(
RuntimeError: Attempted to send an sync request with an AsyncClient instance.

Maybe this is a BUG.

• Python Version: 3.10.8
• httpx Version: 0.25.1

[lee-cq]

I did some debugging:
When the Async.put method has a content parameter, request.stream is an IteratorByteStream, but it should be an AsyncByteStream or its subclass.

[lee-cq]

I do more tests.

1. Work: AsyncClient.put(content=b'test')
2. Work: Client.put(content=open(__file__, 'rb')
3. NOT WOKR: AsyncClient.put(content=open(__file__, 'rb')

[ThermodynamicBeta]

Any solution to this?

[ThermodynamicBeta]

Ah, from the docs: https://www.python-httpx.org/async/

Streaming requests
When sending a streaming request body with an AsyncClient instance, you should use an async bytes generator instead of a bytes generator:

async def upload_bytes():
    ...  # yield byte content

await client.post(url, content=upload_bytes())

[se7enXF]

After using aiofiles.open to replace the raw open function, there's no error. But I don't know how it‘s performs. Here's the code:

import aiofiles

async with aiofiles.open("xxx.file", "rb") as f:
    async with httpx.AsyncClinet() as client:
        resp = await client.request("PUT", "url", data=f)