Skip to content

Sync or Async dispatch #83

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
lovelydinosaur merged 20 commits into from
Jun 10, 2019
Merged

Sync or Async dispatch #83

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
e382d49
Support thread-pooled dispatch
lovelydinosaur May 24, 2019
51fedbf
Add ConcurrencyBackend.run
lovelydinosaur May 24, 2019
d8465df
Initial work towards support byte-iterators on sync request data
lovelydinosaur May 24, 2019
0a6cc1f
Test case for byte iterator content
lovelydinosaur May 24, 2019
9c9db45
byte iterator support for RequestData
lovelydinosaur May 24, 2019
3bc8cfe
Merge branch 'master' into threaded-dispatch
lovelydinosaur May 28, 2019
cda91e9
Add BaseResponse
lovelydinosaur May 28, 2019
2b839b5
Bridge sync/async data in SyncResponse
lovelydinosaur May 30, 2019
7fe2156
Add BaseClient
lovelydinosaur May 30, 2019
1ae5209
SyncResponse -> Response
lovelydinosaur May 30, 2019
bb75f0a
Tweaking type annotation
lovelydinosaur Jun 4, 2019
9f185e1
Distinct classes for Request, AsyncRequest
lovelydinosaur Jun 5, 2019
20e929a
Tweak is_streaming, content in BaseRequest
lovelydinosaur Jun 5, 2019
b89d1fc
Stream handling moves to client
lovelydinosaur Jun 5, 2019
37021de
Handle mediating to AsyncResponse from a standard sync Dispatcher class
lovelydinosaur Jun 5, 2019
6f1e933
Working on thread-pooled dispatcher
lovelydinosaur Jun 6, 2019
11917f0
Support threaded dispatch, inc. streaming requests/responses
lovelydinosaur Jun 7, 2019
28d1dc4
Increase test coverage
lovelydinosaur Jun 7, 2019
5be5598
Coverage and tweaks
lovelydinosaur Jun 10, 2019
12e1b29
Include Accept and User-Agent headers by default
lovelydinosaur Jun 10, 2019
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
21 changes: 19 additions & 2 deletions httpcore/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,25 @@
TooManyRedirects,
WriteTimeout,
)
from .interfaces import BaseReader, BaseWriter, ConcurrencyBackend, Dispatcher, Protocol
from .models import URL, Cookies, Headers, Origin, QueryParams, Request, Response
from .interfaces import (
AsyncDispatcher,
BaseReader,
BaseWriter,
ConcurrencyBackend,
Dispatcher,
Protocol,
)
from .models import (
URL,
AsyncRequest,
AsyncResponse,
Cookies,
Headers,
Origin,
QueryParams,
Request,
Response,
)
from .status_codes import StatusCode, codes

__version__ = "0.3.0"
18 changes: 9 additions & 9 deletions httpcore/api.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
HeaderTypes,
QueryParamTypes,
RequestData,
SyncResponse,
Response,
URLTypes,
)

Expand All @@ -30,7 +30,7 @@ def request(
cert: CertTypes = None,
verify: VerifyTypes = True,
stream: bool = False,
) -> SyncResponse:
) -> Response:
with Client() as client:
return client.request(
method=method,
Expand Down Expand Up @@ -61,7 +61,7 @@ def get(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"GET",
url,
Expand All @@ -88,7 +88,7 @@ def options(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"OPTIONS",
url,
Expand All @@ -115,7 +115,7 @@ def head(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"HEAD",
url,
Expand Down Expand Up @@ -144,7 +144,7 @@ def post(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"POST",
url,
Expand Down Expand Up @@ -175,7 +175,7 @@ def put(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"PUT",
url,
Expand Down Expand Up @@ -206,7 +206,7 @@ def patch(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"PATCH",
url,
Expand Down Expand Up @@ -237,7 +237,7 @@ def delete(
cert: CertTypes = None,
verify: VerifyTypes = True,
timeout: TimeoutTypes = None,
) -> SyncResponse:
) -> Response:
return request(
"DELETE",
url,
Expand Down
6 changes: 3 additions & 3 deletions httpcore/auth.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,15 +1,15 @@
import typing
from base64 import b64encode

from .models import Request
from .models import AsyncRequest


class AuthBase:
"""
Base class that all auth implementations derive from.
"""

def __call__(self, request: Request) -> Request:
def __call__(self, request: AsyncRequest) -> AsyncRequest:
raise NotImplementedError("Auth hooks must be callable.") # pragma: nocover


Expand All @@ -20,7 +20,7 @@ def __init__(
self.username = username
self.password = password

def __call__(self, request: Request) -> Request:
def __call__(self, request: AsyncRequest) -> AsyncRequest:
request.headers["Authorization"] = self.build_auth_header()
return request

Expand Down
Loading