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