Ensure KernelClient's API is complete

Author: davidbrochart

jupyter_client/channels.py

@@ -9,7 +9,7 @@
 from threading import Event
 from threading import Thread
 
-import zmq.asyncio
+from zmq.asyncio import Context, Socket
 
 from .channelsabc import HBChannelABC
 from .session import Session
@@ -49,7 +49,7 @@ class HBChannel(Thread):
 
     def __init__(
         self,
-        context: t.Optional[zmq.asyncio.Context] = None,
+        context: t.Optional[Context] = None,
         session: t.Optional[Session] = None,
         address: t.Union[t.Tuple[str, int], str] = "",
     ):
@@ -193,7 +193,9 @@ def call_handlers(self, since_last_heartbeat: float) -> None:
 class ZMQSocketChannel(object):
     """A ZMQ socket in an async API"""
 
-    def __init__(self, socket: zmq.asyncio.Socket, session: Session, loop: t.Any = None) -> None:
+    def __init__(
+        self, socket: Socket, session: Session, loop: t.Any = None
+    ) -> None:
         """Create a channel.
 
         Parameters
@@ -207,7 +209,7 @@ def __init__(self, socket: zmq.asyncio.Socket, session: Session, loop: t.Any = N
         """
         super().__init__()
 
-        self.socket: t.Optional[zmq.asyncio.Socket] = socket
+        self.socket: t.Optional[Socket] = socket
         self.session = session
 
     async def _recv(self, **kwargs: t.Any) -> t.Dict[str, t.Any]:

jupyter_client/client.py

@@ -90,6 +90,14 @@ class KernelClient(ConnectionFileMixin):
     :meth:`get_shell_msg` to fetch messages from the shell channel.
     """
 
+    get_shell_msg: t.Union[t.Callable, t.Awaitable]
+    get_iopub_msg: t.Union[t.Callable, t.Awaitable]
+    get_stdin_msg: t.Union[t.Callable, t.Awaitable]
+    get_control_msg: t.Union[t.Callable, t.Awaitable]
+    wait_for_ready: t.Union[t.Callable, t.Awaitable] = _async_wait_for_ready
+    is_alive: t.Union[t.Callable, t.Awaitable]
+    execute_interactive: t.Union[t.Callable, t.Awaitable]
+
     # The PyZMQ Context to use for communication with the kernel.
     context = Instance(zmq.asyncio.Context)