From bc4b6fa5c19cf4ff53704f4f15608a5272c8dbb9 Mon Sep 17 00:00:00 2001 From: Denis Bilenko Date: Fri, 12 Jun 2009 14:00:55 +0700 Subject: [PATCH] coros: remove pipe class --- eventlet/coros.py | 21 --------------------- 1 file changed, 21 deletions(-) diff --git a/eventlet/coros.py b/eventlet/coros.py index d43b0a9..ed15361 100644 --- a/eventlet/coros.py +++ b/eventlet/coros.py @@ -451,27 +451,6 @@ def CoroutinePool(*args, **kwargs): return Pool(*args, **kwargs) -class pipe(object): - """ Implementation of pipe using events. Not tested! Not used, either.""" - def __init__(self): - self._event = event() - self._buffer = '' - - def send(self, txt): - self._buffer += txt - evt, self._event = self._event, event() - evt.send() - - def recv(self, num=16384): - if not self._buffer: - self._event.wait() - if num >= len(self._buffer): - buf, self._buffer = self._buffer, '' - else: - buf, self._buffer = self._buffer[:num], self._buffer[num:] - return buf - - class queue(object): """Cross-coroutine queue, using semaphore to synchronize. The API is like a generalization of event to be able to hold more than one