##// END OF EJS Templates
Get rid of QtIOPubChannel class
Thomas Kluyver -
Show More
@@ -206,15 +206,10 b' class QtZMQSocketChannel(SuperQObject, Thread):'
206 206 # Emit the generic signal.
207 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 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 214 Callers should use this method to ensure that :meth:`call_handlers`
220 215 has been called for all messages that have been received on the
@@ -242,8 +237,6 b' class QtIOPubChannel(QtZMQSocketChannel):'
242 237 self.stream.flush()
243 238 self._flushed = True
244 239
245 IOPubChannelABC.register(QtIOPubChannel)
246
247 240
248 241 class QtKernelClient(QtKernelClientMixin, KernelClient):
249 242 """ A KernelClient that provides signals and slots.
@@ -258,7 +251,7 b' class QtKernelClient(QtKernelClientMixin, KernelClient):'
258 251 self._handle_kernel_info_reply(msg)
259 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 255 shell_channel_class = Type(QtZMQSocketChannel)
263 256 stdin_channel_class = Type(QtZMQSocketChannel)
264 257 hb_channel_class = Type(QtHBChannel)
General Comments 0
You need to be logged in to leave comments. Login now