Method _process

python/examples/proton_tornado.py:59–62

(self)

        self._process()

    def _process(self):
        self.reactor.process()
        if not self.reactor.quiesced:
            self.loop.add_callback(self._process)

    def _callback(self, sel, events):
        if self.loop.READ & events: