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 th |
|
|
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(Qt |
|
|
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