We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent def0f73 commit e825f8bCopy full SHA for e825f8b
lib/git/async/channel.py
@@ -1,10 +1,10 @@
1
"""Contains a queue based channel implementation"""
2
from Queue import (
3
- Queue,
4
Empty,
5
Full
6
)
7
+from util import AsyncQueue
8
from time import time
9
import sys
10
@@ -43,7 +43,7 @@ def __init__(self, max_items=0):
43
"""initialize this instance, able to hold max_items at once
44
Write calls will block if the channel is full, until someone reads from it"""
45
self._closed = False
46
- self._queue = Queue(max_items)
+ self._queue = AsyncQueue(max_items)
47
48
49
#{ Interface
0 commit comments