-
Notifications
You must be signed in to change notification settings - Fork 335
Added HttpxAsyncClient
wrapper for httpx.AsyncClient
and support for send_each_for_multicast_async()
#878
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.
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
base: fcm-http2
Are you sure you want to change the base?
Conversation
…tring and type hints
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM! Thanks!
Added a few comments on the extra new lines
from __future__ import annotations | ||
import logging | ||
from typing import Any, Dict, Generator, Optional, Tuple, Union | ||
import httpx |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Note: let's make sure we add the new dependency to setup.py
@@ -153,3 +165,197 @@ def __init__(self, **kwargs): | |||
|
|||
def parse_body(self, resp): | |||
return resp.json() | |||
|
|||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
super nit: is this an extra new line?
# The last yielded response is automatically returned by httpx's auth flow. | ||
|
||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: let's double check these extra new lines
This PR covers:
HttpxAsyncClient
to wraphttpx.AsyncClient
GoogleAuthCredentialFlow
to_http_client
GoogleAuthCredentialFlow
to correctly force a credential refreshsend_each_for_multicast_async()
GoogleAuthCredentialFlow
andHttpxAsyncClient
send_each_for_multicast_async()