Show More
@@ -0,0 +1,44 b'' | |||||
|
1 | # -*- coding: utf-8 -*- | |||
|
2 | import readline | |||
|
3 | import time | |||
|
4 | import sys | |||
|
5 | stdout = sys.stdout | |||
|
6 | class ClientCompleter2p(object): | |||
|
7 | """Client-side completion machinery. | |||
|
8 | ||||
|
9 | How it works: self.complete will be called multiple times, with | |||
|
10 | state=0,1,2,... When state=0 it should compute ALL the completion matches, | |||
|
11 | and then return them for each value of state.""" | |||
|
12 | ||||
|
13 | def __init__(self, km): | |||
|
14 | self.km = km | |||
|
15 | self.matches = [] | |||
|
16 | ||||
|
17 | def complete_request(self,text): | |||
|
18 | line = readline.get_line_buffer() | |||
|
19 | msg = self.km.session.send(self.km.xreq_channel.socket, | |||
|
20 | 'complete_request', | |||
|
21 | dict(text=text, line=line)) | |||
|
22 | msg_matches = None | |||
|
23 | for i in range(5): | |||
|
24 | if self.km.xreq_channel.was_called(): | |||
|
25 | msg_xreq = self.km.xreq_channel.get_msg() | |||
|
26 | if msg["header"]['session'] == msg_xreq["parent_header"]['session'] : | |||
|
27 | if msg_xreq["content"]["status"] == 'ok' : | |||
|
28 | if msg_xreq["msg_type"] == "complete_reply" : | |||
|
29 | msg_matches = msg_xreq["content"]["matches"] | |||
|
30 | time.sleep(0.1) | |||
|
31 | return msg_matches | |||
|
32 | ||||
|
33 | def complete(self, text, state): | |||
|
34 | if state == 0 : | |||
|
35 | self.matches = self.complete_request(text) | |||
|
36 | # send completion request to kernel | |||
|
37 | # Give the kernel up to 0.5s to respond | |||
|
38 | if self.matches is None: | |||
|
39 | self.matches = [] | |||
|
40 | print('WARNING: Kernel timeout on tab completion.') | |||
|
41 | return self.matches | |||
|
42 | ||||
|
43 | ||||
|
44 | No newline at end of file |
General Comments 0
You need to be logged in to leave comments.
Login now