Method _schedule

python/examples/proton_tornado.py:50–52

(self, sel)

        return events

    def _schedule(self, sel):
        if sel.deadline:
            self.loop.add_timeout(sel.deadline, lambda: self._expired(sel))

    def _expired(self, sel):
        self.reactor.mark()