issue #249: fix Poller.from_existing() for v2 API

pull/255/head
David Wilson 7 years ago
parent 5645629e5d
commit aa8f786413

@ -504,10 +504,10 @@ class Poller(mitogen.core.Poller):
@classmethod @classmethod
def from_existing(cls, poller): def from_existing(cls, poller):
self = cls() self = cls()
for reader in poller.readers: for fd, data in poller.readers:
self.start_receive(reader.stream) self.start_receive(fd, data)
for writer in poller.writers: for fd, data in poller.writers:
self.start_transmit(writer.stream) self.start_transmit(fd, data)
class KqueuePoller(Poller): class KqueuePoller(Poller):

Loading…
Cancel
Save