Show More
@@ -75,6 +75,9 b' class doublepipe(object):' | |||||
75 | act = fds |
|
75 | act = fds | |
76 | return (self._main.fileno() in act, self._side.fileno() in act) |
|
76 | return (self._main.fileno() in act, self._side.fileno() in act) | |
77 |
|
77 | |||
|
78 | def write(self, data): | |||
|
79 | return self._call('write', data) | |||
|
80 | ||||
78 | def read(self, size): |
|
81 | def read(self, size): | |
79 | return self._call('read', size) |
|
82 | return self._call('read', size) | |
80 |
|
83 | |||
@@ -102,6 +105,9 b' class doublepipe(object):' | |||||
102 | def close(self): |
|
105 | def close(self): | |
103 | return self._main.close() |
|
106 | return self._main.close() | |
104 |
|
107 | |||
|
108 | def flush(self): | |||
|
109 | return self._main.flush() | |||
|
110 | ||||
105 | class sshpeer(wireproto.wirepeer): |
|
111 | class sshpeer(wireproto.wirepeer): | |
106 | def __init__(self, ui, path, create=False): |
|
112 | def __init__(self, ui, path, create=False): | |
107 | self._url = path |
|
113 | self._url = path |
General Comments 0
You need to be logged in to leave comments.
Login now