Reverted my change from 26fa1e236f84, because it was totally incorrect. Note to self: don't 'fix' things that aren't bugs.
This commit is contained in:
@@ -23,8 +23,7 @@ class Hub(BaseHub):
|
||||
self.modify = self.poll.register
|
||||
|
||||
def add(self, evtype, fileno, cb):
|
||||
oldlisteners = bool(self.listeners[READ].get(fileno) or
|
||||
self.listeners[WRITE].get(fileno))
|
||||
oldlisteners = bool(self.listeners[evtype].get(fileno))
|
||||
listener = super(Hub, self).add(evtype, fileno, cb)
|
||||
if not oldlisteners:
|
||||
# Means we've added a new listener
|
||||
|
Reference in New Issue
Block a user