Show More
@@ -562,7 +562,7 b' class ConnectionFileMixin(LoggingConfigurable):' | |||||
562 | return self._create_connected_socket('hb', identity=identity) |
|
562 | return self._create_connected_socket('hb', identity=identity) | |
563 |
|
563 | |||
564 | def connect_control(self, identity=None): |
|
564 | def connect_control(self, identity=None): | |
565 |
"""return zmq Socket connected to the |
|
565 | """return zmq Socket connected to the Control channel""" | |
566 | return self._create_connected_socket('control', identity=identity) |
|
566 | return self._create_connected_socket('control', identity=identity) | |
567 |
|
567 | |||
568 |
|
568 |
@@ -17,10 +17,6 b' class ChannelQObject(SuperQObject):' | |||||
17 | # Emitted when the channel is stopped. |
|
17 | # Emitted when the channel is stopped. | |
18 | stopped = QtCore.Signal() |
|
18 | stopped = QtCore.Signal() | |
19 |
|
19 | |||
20 | #--------------------------------------------------------------------------- |
|
|||
21 | # Channel interface |
|
|||
22 | #--------------------------------------------------------------------------- |
|
|||
23 |
|
||||
24 | def start(self): |
|
20 | def start(self): | |
25 | """ Reimplemented to emit signal. |
|
21 | """ Reimplemented to emit signal. | |
26 | """ |
|
22 | """ | |
@@ -61,10 +57,6 b' class QtShellChannelMixin(ChannelQObject):' | |||||
61 | history_reply = QtCore.Signal(object) |
|
57 | history_reply = QtCore.Signal(object) | |
62 | kernel_info_reply = QtCore.Signal(object) |
|
58 | kernel_info_reply = QtCore.Signal(object) | |
63 |
|
59 | |||
64 | #--------------------------------------------------------------------------- |
|
|||
65 | # 'ShellChannel' interface |
|
|||
66 | #--------------------------------------------------------------------------- |
|
|||
67 |
|
||||
68 | def call_handlers(self, msg): |
|
60 | def call_handlers(self, msg): | |
69 | """ Reimplemented to emit signals instead of making callbacks. |
|
61 | """ Reimplemented to emit signals instead of making callbacks. | |
70 | """ |
|
62 | """ | |
@@ -108,10 +100,6 b' class QtIOPubChannelMixin(ChannelQObject):' | |||||
108 | # Emitted when a shutdown is noticed. |
|
100 | # Emitted when a shutdown is noticed. | |
109 | shutdown_reply_received = QtCore.Signal(object) |
|
101 | shutdown_reply_received = QtCore.Signal(object) | |
110 |
|
102 | |||
111 | #--------------------------------------------------------------------------- |
|
|||
112 | # 'IOPubChannel' interface |
|
|||
113 | #--------------------------------------------------------------------------- |
|
|||
114 |
|
||||
115 | def call_handlers(self, msg): |
|
103 | def call_handlers(self, msg): | |
116 | """ Reimplemented to emit signals instead of making callbacks. |
|
104 | """ Reimplemented to emit signals instead of making callbacks. | |
117 | """ |
|
105 | """ | |
@@ -122,8 +110,6 b' class QtIOPubChannelMixin(ChannelQObject):' | |||||
122 | signal = getattr(self, msg_type + '_received', None) |
|
110 | signal = getattr(self, msg_type + '_received', None) | |
123 | if signal: |
|
111 | if signal: | |
124 | signal.emit(msg) |
|
112 | signal.emit(msg) | |
125 | elif msg_type in ('stdout', 'stderr'): |
|
|||
126 | self.stream_received.emit(msg) |
|
|||
127 |
|
113 | |||
128 | def flush(self): |
|
114 | def flush(self): | |
129 | """ Reimplemented to ensure that signals are dispatched immediately. |
|
115 | """ Reimplemented to ensure that signals are dispatched immediately. | |
@@ -140,10 +126,6 b' class QtStdInChannelMixin(ChannelQObject):' | |||||
140 | # Emitted when an input request is received. |
|
126 | # Emitted when an input request is received. | |
141 | input_requested = QtCore.Signal(object) |
|
127 | input_requested = QtCore.Signal(object) | |
142 |
|
128 | |||
143 | #--------------------------------------------------------------------------- |
|
|||
144 | # 'StdInChannel' interface |
|
|||
145 | #--------------------------------------------------------------------------- |
|
|||
146 |
|
||||
147 | def call_handlers(self, msg): |
|
129 | def call_handlers(self, msg): | |
148 | """ Reimplemented to emit signals instead of making callbacks. |
|
130 | """ Reimplemented to emit signals instead of making callbacks. | |
149 | """ |
|
131 | """ | |
@@ -161,14 +143,9 b' class QtHBChannelMixin(ChannelQObject):' | |||||
161 | # Emitted when the kernel has died. |
|
143 | # Emitted when the kernel has died. | |
162 | kernel_died = QtCore.Signal(object) |
|
144 | kernel_died = QtCore.Signal(object) | |
163 |
|
145 | |||
164 | #--------------------------------------------------------------------------- |
|
|||
165 | # 'HBChannel' interface |
|
|||
166 | #--------------------------------------------------------------------------- |
|
|||
167 |
|
||||
168 | def call_handlers(self, since_last_heartbeat): |
|
146 | def call_handlers(self, since_last_heartbeat): | |
169 | """ Reimplemented to emit signals instead of making callbacks. |
|
147 | """ Reimplemented to emit signals instead of making callbacks. | |
170 | """ |
|
148 | """ | |
171 | # Emit the generic signal. |
|
|||
172 | self.kernel_died.emit(since_last_heartbeat) |
|
149 | self.kernel_died.emit(since_last_heartbeat) | |
173 |
|
150 | |||
174 |
|
151 |
General Comments 0
You need to be logged in to leave comments.
Login now