Added a LockingQueue to recipes. When get() method is called this queue locks an item instead of removing it.
…, removed 'ascii'
watcher callback invalid only if None
Fix leak of os.pipe() file descriptors
And guard against hitting a closed pipe in _call()
Moved pipe creation into ConnectionHandler.start() and closes FDs when zk_loop ends (triggered by stop()).
…e the KazooRetry. Fixes Issue #48.
pip cannot update distribute under py3k (see pypa/pip#650)