Merge pull request #447 from JohanMabille/control

Exposes control channel in public API

.gitignore

@@ -14,6 +14,7 @@ __pycache__
 .coverage
 .cache
 absolute.json
+*.swp
 
 # Sphinx documentation
 _build

jupyter_client/ioloop/manager.py

@@ -57,6 +57,7 @@ def stop_restarter(self):
                 self._restarter = None
 
     connect_shell = as_zmqstream(KernelManager.connect_shell)
+    connect_control = as_zmqstream(KernelManager.connect_control)
     connect_iopub = as_zmqstream(KernelManager.connect_iopub)
     connect_stdin = as_zmqstream(KernelManager.connect_stdin)
     connect_hb = as_zmqstream(KernelManager.connect_hb)

jupyter_client/multikernelmanager.py

@@ -284,6 +284,22 @@ def connect_shell(self, kernel_id, identity=None):
         stream : zmq Socket or ZMQStream
         """
 
+    @kernel_method
+    def connect_control(self, kernel_id, identity=None):
+        """Return a zmq Socket connected to the control channel.
+
+        Parameters
+        ==========
+        kernel_id : uuid
+            The id of the kernel
+        identity : bytes (optional)
+            The zmq identity of the socket
+
+        Returns
+        =======
+        stream : zmq Socket or ZMQStream
+        """
+
     @kernel_method
     def connect_stdin(self, kernel_id, identity=None):
         """Return a zmq Socket connected to the stdin channel.