def __init__(self, app, poll_size=5): self.app = app self.dq = DeferredQueue(size=poll_size) self.queue = None