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
@@ -1073,10 +1075,10 @@ class ServiceStub(ABC):
1073
1075
1074
1076
def __init__ (
1075
1077
self ,
1076
- channel : grpclib . client . Channel ,
1078
+ channel : " Channel" ,
1077
1079
* ,
1078
1080
timeout : Optional [float ] = None ,
1079
- deadline : Optional [grpclib . metadata . Deadline ] = None ,
1081
+ deadline : Optional [" Deadline" ] = None ,
1080
1082
metadata : Optional [_MetadataLike ] = None ,
1081
1083
) -> None :
1082
1084
self .channel = channel
@@ -1087,7 +1089,7 @@ def __init__(
1087
1089
def __resolve_request_kwargs (
1088
1090
self ,
1089
1091
timeout : Optional [float ],
1090
- deadline : Optional [grpclib . metadata . Deadline ],
1092
+ deadline : Optional [" Deadline" ],
1091
1093
metadata : Optional [_MetadataLike ],
1092
1094
):
1093
1095
return {
@@ -1103,7 +1105,7 @@ async def _unary_unary(
1103
1105
response_type : Type [T ],
1104
1106
* ,
1105
1107
timeout : Optional [float ] = None ,
1106
- deadline : Optional [grpclib . metadata . Deadline ] = None ,
1108
+ deadline : Optional [" Deadline" ] = None ,
1107
1109
metadata : Optional [_MetadataLike ] = None ,
1108
1110
) -> T :
1109
1111
"""Make a unary request and return the response."""
@@ -1126,7 +1128,7 @@ async def _unary_stream(
1126
1128
response_type : Type [T ],
1127
1129
* ,
1128
1130
timeout : Optional [float ] = None ,
1129
- deadline : Optional [grpclib . metadata . Deadline ] = None ,
1131
+ deadline : Optional [" Deadline" ] = None ,
1130
1132
metadata : Optional [_MetadataLike ] = None ,
1131
1133
) -> AsyncGenerator [T , None ]:
1132
1134
"""Make a unary request and return the stream response iterator."""
0 commit comments