Deprecating coros.Queue and coros.Channel

This commit is contained in:
Ryan Williams
2010-01-23 21:29:48 -05:00
parent ec802dd8c6
commit d877a490c3

View File

@@ -135,6 +135,9 @@ def CoroutinePool(*args, **kwargs):
class Queue(object): class Queue(object):
def __init__(self): def __init__(self):
warnings.warn("coros.Queue is deprecated. Please use "
"eventlet.queue.Queue instead.",
DeprecationWarning, stacklevel=2)
self.items = collections.deque() self.items = collections.deque()
self._waiters = set() self._waiters = set()
@@ -203,6 +206,9 @@ class Queue(object):
class Channel(object): class Channel(object):
def __init__(self, max_size=0): def __init__(self, max_size=0):
warnings.warn("coros.Channel is deprecated. Please use "
"eventlet.queue.Queue(0) instead.",
DeprecationWarning, stacklevel=2)
self.max_size = max_size self.max_size = max_size
self.items = collections.deque() self.items = collections.deque()
self._waiters = set() self._waiters = set()