1 from concurrent.futures import Future
2 from typing import Callable, Optional, Text, Type
4 from google.protobuf.descriptor import MethodDescriptor, ServiceDescriptor
5 from google.protobuf.message import Message
7 class RpcException(Exception): ...
11 def GetDescriptor() -> ServiceDescriptor: ...
14 method_descriptor: MethodDescriptor,
15 rpc_controller: RpcController,
17 done: Optional[Callable[[Message], None]],
18 ) -> Optional[Future[Message]]: ...
19 def GetRequestClass(self, method_descriptor: MethodDescriptor) -> Type[Message]: ...
20 def GetResponseClass(self, method_descriptor: MethodDescriptor) -> Type[Message]: ...
23 def Reset(self) -> None: ...
24 def Failed(self) -> bool: ...
25 def ErrorText(self) -> Optional[Text]: ...
26 def StartCancel(self) -> None: ...
27 def SetFailed(self, reason: Text) -> None: ...
28 def IsCanceled(self) -> bool: ...
29 def NotifyOnCancel(self, callback: Callable[[], None]) -> None: ...
34 method_descriptor: MethodDescriptor,
35 rpc_controller: RpcController,
37 response_class: Type[Message],
38 done: Optional[Callable[[Message], None]],
39 ) -> Optional[Future[Message]]: ...