|
|
|
@ -14,10 +14,10 @@ |
|
|
|
|
"""Invocation-side implementation of gRPC Asyncio Python.""" |
|
|
|
|
|
|
|
|
|
import asyncio |
|
|
|
|
from functools import partial |
|
|
|
|
import logging |
|
|
|
|
import enum |
|
|
|
|
from typing import AsyncIterable, Awaitable, Optional |
|
|
|
|
import logging |
|
|
|
|
from functools import partial |
|
|
|
|
from typing import AsyncIterable, Awaitable, Optional, Tuple |
|
|
|
|
|
|
|
|
|
import grpc |
|
|
|
|
from grpc import _common |
|
|
|
@ -25,7 +25,8 @@ from grpc._cython import cygrpc |
|
|
|
|
|
|
|
|
|
from . import _base_call |
|
|
|
|
from ._typing import (DeserializingFunction, DoneCallbackType, MetadataType, |
|
|
|
|
RequestType, ResponseType, SerializingFunction) |
|
|
|
|
MetadatumType, RequestType, ResponseType, |
|
|
|
|
SerializingFunction) |
|
|
|
|
|
|
|
|
|
__all__ = 'AioRpcError', 'Call', 'UnaryUnaryCall', 'UnaryStreamCall' |
|
|
|
|
|
|
|
|
@ -161,7 +162,7 @@ class Call: |
|
|
|
|
_loop: asyncio.AbstractEventLoop |
|
|
|
|
_code: grpc.StatusCode |
|
|
|
|
_cython_call: cygrpc._AioCall |
|
|
|
|
_metadata: MetadataType |
|
|
|
|
_metadata: Tuple[MetadatumType] |
|
|
|
|
_request_serializer: SerializingFunction |
|
|
|
|
_response_deserializer: DeserializingFunction |
|
|
|
|
|
|
|
|
|