##// END OF EJS Templates
Get rid of QtIOPubChannel class
Thomas Kluyver -
Show More
@@ -206,15 +206,10 b' class QtZMQSocketChannel(SuperQObject, Thread):'
206 # Emit the generic signal.
206 # Emit the generic signal.
207 self.message_received.emit(msg)
207 self.message_received.emit(msg)
208
208
209
210 class QtIOPubChannel(QtZMQSocketChannel):
211 """The iopub channel which listens for messages that the kernel publishes.
212
213 This channel is where all output is published to frontends.
214 """
215
216 def flush(self, timeout=1.0):
209 def flush(self, timeout=1.0):
217 """Immediately processes all pending messages on the iopub channel.
210 """Immediately processes all pending messages on this channel.
211
212 This is only used for the IOPub channel.
218
213
219 Callers should use this method to ensure that :meth:`call_handlers`
214 Callers should use this method to ensure that :meth:`call_handlers`
220 has been called for all messages that have been received on the
215 has been called for all messages that have been received on the
@@ -242,8 +237,6 b' class QtIOPubChannel(QtZMQSocketChannel):'
242 self.stream.flush()
237 self.stream.flush()
243 self._flushed = True
238 self._flushed = True
244
239
245 IOPubChannelABC.register(QtIOPubChannel)
246
247
240
248 class QtKernelClient(QtKernelClientMixin, KernelClient):
241 class QtKernelClient(QtKernelClientMixin, KernelClient):
249 """ A KernelClient that provides signals and slots.
242 """ A KernelClient that provides signals and slots.
@@ -258,7 +251,7 b' class QtKernelClient(QtKernelClientMixin, KernelClient):'
258 self._handle_kernel_info_reply(msg)
251 self._handle_kernel_info_reply(msg)
259 self.shell_channel.message_received.disconnect(self._check_kernel_info_reply)
252 self.shell_channel.message_received.disconnect(self._check_kernel_info_reply)
260
253
261 iopub_channel_class = Type(QtIOPubChannel)
254 iopub_channel_class = Type(QtZMQSocketChannel)
262 shell_channel_class = Type(QtZMQSocketChannel)
255 shell_channel_class = Type(QtZMQSocketChannel)
263 stdin_channel_class = Type(QtZMQSocketChannel)
256 stdin_channel_class = Type(QtZMQSocketChannel)
264 hb_channel_class = Type(QtHBChannel)
257 hb_channel_class = Type(QtHBChannel)
General Comments 0
You need to be logged in to leave comments. Login now