Skip to content

Update RequestX adapter for v1.0.2 with httpx-like API #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
wuqunfei merged 4 commits into from
Jan 27, 2026
Merged

Update RequestX adapter for v1.0.2 with httpx-like API #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
b5e0618
Update requestx adapter for v1.0.2 API (httpx-like interface)
claude Jan 27, 2026
a80ede8
Bump requestx version requirement to 1.0.3
claude Jan 27, 2026
bbcc21b
Align requestx adapter formatting with httpx adapter
claude Jan 27, 2026
3b81937
Bump version to 5.1.1
claude Jan 27, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
104 changes: 32 additions & 72 deletions http_benchmark/clients/requestx_adapter.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
"""RequestX HTTP client adapter for the HTTP benchmark framework."""

import time
import asyncio
from typing import Any, Dict

Expand All @@ -15,28 +14,29 @@ class RequestXAdapter(BaseHTTPAdapter):

def __init__(self):
super().__init__("requestx")
self.session = None
self.async_session = None
self.client = None
self.async_client = None
self.verify_ssl = True

def __enter__(self):
"""Initialize session when entering sync context."""
self.session = requestx.Session()
"""Initialize sync client when entering sync context."""
self.client = requestx.Client(verify=self.verify_ssl)
return self

def __exit__(self, exc_type, exc_val, exc_tb):
"""Close session when exiting sync context."""
if self.session:
self.session.close()
"""Close sync client when exiting sync context."""
if self.client:
self.client.close()

async def __aenter__(self):
"""Initialize session when entering async context."""
self.async_session = requestx.Session()
"""Initialize async client when entering async context."""
self.async_client = requestx.AsyncClient(verify=self.verify_ssl)
return self

async def __aexit__(self, exc_type, exc_val, exc_tb):
"""Close session when exiting async context."""
if self.async_session:
self.async_session.close()
"""Close async client when exiting async context."""
if self.async_client:
await self.async_client.aclose()

def make_request(self, request: HTTPRequest) -> Dict[str, Any]:
"""Make an HTTP request using the requestx library."""
Expand All @@ -45,27 +45,16 @@ def make_request(self, request: HTTPRequest) -> Dict[str, Any]:
url = request.url
headers = request.headers
timeout = request.timeout
verify_ssl = request.verify_ssl

data = request.body if request.body else None

kwargs = {"headers": headers, "timeout": timeout, "verify": verify_ssl}
if data is not None:
kwargs["data"] = data

start_time = time.time()
response = self.session.request(method, url, **kwargs)
end_time = time.time()

response_time = end_time - start_time
if hasattr(response, "elapsed"):
response_time = response.elapsed.total_seconds()
response = self.client.request(method=method, url=url, headers=headers, content=data, timeout=timeout)

return {
"status_code": response.status_code,
"headers": dict(response.headers),
"content": response.text,
"response_time": response_time,
"response_time": response.elapsed.total_seconds(),
"url": str(response.url),
"success": True,
"error": None,
Expand All @@ -88,27 +77,18 @@ async def make_request_async(self, request: HTTPRequest) -> Dict[str, Any]:
url = request.url
headers = request.headers
timeout = request.timeout
verify_ssl = request.verify_ssl

data = request.body if request.body else None

kwargs = {"headers": headers, "timeout": timeout, "verify": verify_ssl}
if data is not None:
kwargs["data"] = data

start_time = asyncio.get_event_loop().time()
response = await self.async_session.request(method, url, **kwargs)
response = await self.async_client.request(method=method, url=url, headers=headers, content=data, timeout=timeout)
end_time = asyncio.get_event_loop().time()

response_time = end_time - start_time
if hasattr(response, "elapsed"):
response_time = response.elapsed.total_seconds()

return {
"status_code": response.status_code,
"headers": dict(response.headers),
"content": response.text,
"response_time": response_time,
"response_time": end_time - start_time,
"url": str(response.url),
"success": True,
"error": None,
Expand All @@ -131,40 +111,31 @@ def make_request_stream(self, request: HTTPRequest) -> Dict[str, Any]:
url = request.url
headers = request.headers
timeout = request.timeout
verify_ssl = request.verify_ssl

data = request.body if request.body else None

kwargs = {"headers": headers, "timeout": timeout, "verify": verify_ssl}
if data is not None:
kwargs["data"] = data
import time

start_time = time.time()

# RequestX doesn't have native streaming like requests
# Fall back to regular request and simulate streaming behavior
response = self.session.request(method, url, **kwargs)

# Simulate chunked reading
content = response.content
chunk_count = 1 if content else 0
with self.client.stream(method=method, url=url, headers=headers, content=data, timeout=timeout) as response:
content = b""
for chunk in response.iter_bytes(chunk_size=8192):
if chunk:
content += chunk

end_time = time.time()

response_time = end_time - start_time
if hasattr(response, "elapsed"):
response_time = response.elapsed.total_seconds()

return {
"status_code": response.status_code,
"headers": dict(response.headers),
"content": content.decode("utf-8") if content else "",
"response_time": response_time,
"response_time": end_time - start_time,
"url": str(response.url),
"success": True,
"error": None,
"streamed": True,
"chunk_count": chunk_count,
"chunk_count": len(content) // 8192 + (1 if len(content) % 8192 > 0 else 0),
}
except Exception as e:
return {
Expand All @@ -185,40 +156,29 @@ async def make_request_stream_async(self, request: HTTPRequest) -> Dict[str, Any
url = request.url
headers = request.headers
timeout = request.timeout
verify_ssl = request.verify_ssl

data = request.body if request.body else None

kwargs = {"headers": headers, "timeout": timeout, "verify": verify_ssl}
if data is not None:
kwargs["data"] = data

start_time = asyncio.get_event_loop().time()

# RequestX doesn't have native streaming like requests
# Fall back to regular request and simulate streaming behavior
response = await self.async_session.request(method, url, **kwargs)

# Simulate chunked reading
content = response.content
chunk_count = 1 if content else 0
async with self.async_client.stream(method=method, url=url, headers=headers, content=data, timeout=timeout) as response:
content = b""
async for chunk in response.aiter_bytes(chunk_size=8192):
if chunk:
content += chunk

end_time = asyncio.get_event_loop().time()

response_time = end_time - start_time
if hasattr(response, "elapsed"):
response_time = response.elapsed.total_seconds()

return {
"status_code": response.status_code,
"headers": dict(response.headers),
"content": content.decode("utf-8") if content else "",
"response_time": response_time,
"response_time": end_time - start_time,
"url": str(response.url),
"success": True,
"error": None,
"streamed": True,
"chunk_count": chunk_count,
"chunk_count": len(content) // 8192 + (1 if len(content) % 8192 > 0 else 0),
}
except Exception as e:
return {
Expand Down
4 changes: 2 additions & 2 deletions pyproject.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"

[project]
name = "http-client-benchmarker"
version = "5.1.0"
version = "5.1.1"
description = "A Python HTTP Client Performance Benchmark Framework"
readme = "README.md"
authors = [{name = "Qunfei Wu", email = "wu.qunfei@gmail.com"}]
Expand All @@ -19,7 +19,7 @@ classifiers = [
]
dependencies = [
"requests>=2.31.0",
"requestx>=0.1.0",
"requestx>=1.0.3",
"httpx>=0.27.0",
"aiohttp>=3.9.0",
"urllib3>=2.0.0",
Expand Down
Loading