oops, don't forget to add the empty() method
This commit is contained in:
parent
e7afd83308
commit
f765980313
|
@ -154,6 +154,23 @@ class BufferedPipe (object):
|
||||||
|
|
||||||
return out
|
return out
|
||||||
|
|
||||||
|
def empty(self):
|
||||||
|
"""
|
||||||
|
Clear out the buffer and return all data that was in it.
|
||||||
|
|
||||||
|
@return: any data that was in the buffer prior to clearing it out
|
||||||
|
@rtype: str
|
||||||
|
"""
|
||||||
|
self._lock.acquire()
|
||||||
|
try:
|
||||||
|
out = self._buffer.tostring()
|
||||||
|
del self._buffer[:]
|
||||||
|
if (self._event is not None) and not self._closed:
|
||||||
|
self._event.clear()
|
||||||
|
return out
|
||||||
|
finally:
|
||||||
|
self._lock.release()
|
||||||
|
|
||||||
def close(self):
|
def close(self):
|
||||||
"""
|
"""
|
||||||
Close this pipe object. Future calls to L{read} after the buffer
|
Close this pipe object. Future calls to L{read} after the buffer
|
||||||
|
|
Loading…
Reference in New Issue