27
27
TYPE_CHECKING ,
28
28
)
29
29
30
- import grpclib . client
30
+
31
31
import grpclib .const
32
32
import stringcase
33
33
34
34
from .casing import safe_snake_case
35
35
36
36
if TYPE_CHECKING :
37
37
from grpclib ._protocols import IProtoMessage
38
+ from grpclib .client import Channel
39
+ from grpclib .metadata import Deadline
38
40
39
41
if not (sys .version_info .major == 3 and sys .version_info .minor >= 7 ):
40
42
# Apply backport of datetime.fromisoformat from 3.7
@@ -1013,10 +1015,10 @@ class ServiceStub(ABC):
1013
1015
1014
1016
def __init__ (
1015
1017
self ,
1016
- channel : grpclib . client . Channel ,
1018
+ channel : ' Channel' ,
1017
1019
* ,
1018
1020
timeout : Optional [float ] = None ,
1019
- deadline : Optional [grpclib . metadata . Deadline ] = None ,
1021
+ deadline : Optional [' Deadline' ] = None ,
1020
1022
metadata : Optional [_MetadataLike ] = None ,
1021
1023
) -> None :
1022
1024
self .channel = channel
@@ -1027,7 +1029,7 @@ def __init__(
1027
1029
def __resolve_request_kwargs (
1028
1030
self ,
1029
1031
timeout : Optional [float ],
1030
- deadline : Optional [grpclib . metadata . Deadline ],
1032
+ deadline : Optional [' Deadline' ],
1031
1033
metadata : Optional [_MetadataLike ],
1032
1034
):
1033
1035
return {
@@ -1043,7 +1045,7 @@ async def _unary_unary(
1043
1045
response_type : Type [T ],
1044
1046
* ,
1045
1047
timeout : Optional [float ] = None ,
1046
- deadline : Optional [grpclib . metadata . Deadline ] = None ,
1048
+ deadline : Optional [' Deadline' ] = None ,
1047
1049
metadata : Optional [_MetadataLike ] = None ,
1048
1050
) -> T :
1049
1051
"""Make a unary request and return the response."""
@@ -1066,7 +1068,7 @@ async def _unary_stream(
1066
1068
response_type : Type [T ],
1067
1069
* ,
1068
1070
timeout : Optional [float ] = None ,
1069
- deadline : Optional [grpclib . metadata . Deadline ] = None ,
1071
+ deadline : Optional [' Deadline' ] = None ,
1070
1072
metadata : Optional [_MetadataLike ] = None ,
1071
1073
) -> AsyncGenerator [T , None ]:
1072
1074
"""Make a unary request and return the stream response iterator."""
0 commit comments