##// END OF EJS Templates
Merge pull request #7095 from takluyver/misc-fixing-stuff...
Min RK -
r19185:919f6baf merge
parent child Browse files
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 Heartbeat channel"""
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