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