support blocking is_complete in inprocess

ipykernel/inprocess/client.py

@@ -50,9 +50,18 @@ class InProcessKernelClient(KernelClient):
     #--------------------------------------------------------------------------
     # Channel management methods
     #--------------------------------------------------------------------------
+
+    def _blocking_class_default(self):
+        from .blocking import BlockingInProcessKernelClient
+        return BlockingInProcessKernelClient
+
+    def get_connection_info(self):
+        d = super(InProcessKernelClient, self).get_connection_info()
+        d['kernel'] = self.kernel
+        return d
 
     def start_channels(self, *args, **kwargs):
-        super(InProcessKernelClient, self).start_channels(self)
+        super(InProcessKernelClient, self).start_channels()
         self.kernel.frontends.append(self)
 
     @property
@@ -133,6 +142,10 @@ def input(self, string):
             raise RuntimeError('Cannot send input reply. No kernel exists.')
         self.kernel.raw_input_str = string
 
+    def is_complete(self, code):
+        msg = self.session.msg('is_complete_request', {'code': code})
+        self._dispatch_to_kernel(msg)
+        return msg['header']['msg_id']
 
     def _dispatch_to_kernel(self, msg):
         """ Send a message to the kernel and handle a reply.

ipykernel/inprocess/manager.py

@@ -24,6 +24,9 @@ class InProcessKernelManager(KernelManager):
                       allow_none=True)
     # the client class for KM.client() shortcut
     client_class = DottedObjectName('ipykernel.inprocess.BlockingInProcessKernelClient')
+    def _blocking_class_default(self):
+        from .blocking import BlockingInProcessKernelClient
+        return BlockingInProcessKernelClient
 
     def _session_default(self):
         # don't sign in-process messages