##// END OF EJS Templates
Rename _queue_send to send
Thomas Kluyver -
Show More
@@ -82,7 +82,7 b' class ZMQSocketChannel(object):'
82 82 def is_alive(self):
83 83 return (self.socket is not None)
84 84
85 def _queue_send(self, msg):
85 def send(self, msg):
86 86 """Pass a message to the ZMQ socket to send
87 87 """
88 88 self.session.send(self.socket, msg)
@@ -249,7 +249,7 b' class KernelClient(ConnectionFileMixin):'
249 249 allow_stdin=allow_stdin,
250 250 )
251 251 msg = self.session.msg('execute_request', content)
252 self.shell_channel._queue_send(msg)
252 self.shell_channel.send(msg)
253 253 return msg['header']['msg_id']
254 254
255 255 def complete(self, code, cursor_pos=None):
@@ -272,7 +272,7 b' class KernelClient(ConnectionFileMixin):'
272 272 cursor_pos = len(code)
273 273 content = dict(code=code, cursor_pos=cursor_pos)
274 274 msg = self.session.msg('complete_request', content)
275 self.shell_channel._queue_send(msg)
275 self.shell_channel.send(msg)
276 276 return msg['header']['msg_id']
277 277
278 278 def inspect(self, code, cursor_pos=None, detail_level=0):
@@ -301,7 +301,7 b' class KernelClient(ConnectionFileMixin):'
301 301 detail_level=detail_level,
302 302 )
303 303 msg = self.session.msg('inspect_request', content)
304 self.shell_channel._queue_send(msg)
304 self.shell_channel.send(msg)
305 305 return msg['header']['msg_id']
306 306
307 307 def history(self, raw=True, output=False, hist_access_type='range', **kwargs):
@@ -339,13 +339,13 b' class KernelClient(ConnectionFileMixin):'
339 339 content = dict(raw=raw, output=output, hist_access_type=hist_access_type,
340 340 **kwargs)
341 341 msg = self.session.msg('history_request', content)
342 self.shell_channel._queue_send(msg)
342 self.shell_channel.send(msg)
343 343 return msg['header']['msg_id']
344 344
345 345 def kernel_info(self):
346 346 """Request kernel info."""
347 347 msg = self.session.msg('kernel_info_request')
348 self.shell_channel._queue_send(msg)
348 self.shell_channel.send(msg)
349 349 return msg['header']['msg_id']
350 350
351 351 def _handle_kernel_info_reply(self, msg):
@@ -371,19 +371,19 b' class KernelClient(ConnectionFileMixin):'
371 371 # Send quit message to kernel. Once we implement kernel-side setattr,
372 372 # this should probably be done that way, but for now this will do.
373 373 msg = self.session.msg('shutdown_request', {'restart':restart})
374 self.shell_channel._queue_send(msg)
374 self.shell_channel.send(msg)
375 375 return msg['header']['msg_id']
376 376
377 377 def is_complete(self, code):
378 378 msg = self.session.msg('is_complete_request', {'code': code})
379 self.shell_channel._queue_send(msg)
379 self.shell_channel.send(msg)
380 380 return msg['header']['msg_id']
381 381
382 382 def input(self, string):
383 383 """Send a string of raw input to the kernel."""
384 384 content = dict(value=string)
385 385 msg = self.session.msg('input_reply', content)
386 self.stdin_channel._queue_send(msg)
386 self.stdin_channel.send(msg)
387 387
388 388
389 389 KernelClientABC.register(KernelClient)
@@ -96,7 +96,7 b' class QtZMQSocketChannel(SuperQObject):'
96 96 pass
97 97 self.socket = None
98 98
99 def _queue_send(self, msg):
99 def send(self, msg):
100 100 """Queue a message to be sent from the IOLoop's thread.
101 101
102 102 Parameters
General Comments 0
You need to be logged in to leave comments. Login now