Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(3)  |  Call(3)  |  Derive(0)  |  Import(0)

        def loop(map = None, count = None, timeout=None):
    if map is None:
        map = asyncore.socket_map
    if count is None:
        while (map or timer_heap):
            loop1(map, timeout)
    else:
        while (map or timer_heap) and count > 0:
            loop1(map, timeout)
            count = count - 1
        run_timers_internal()
        


src/g/o/gocept.amqprun-0.13.0/src/gocept/amqprun/connection.py   gocept.amqprun(Download)
        # the main thread about it using the notifier pipe.
        if self.is_main_thread:
            pika.asyncore_loop(self.socket_map, count=1, timeout=timeout)
            if self._close_now:
                self.close()

src/a/m/amqp-demo-HEAD/pika_client.py   amqp-demo(Download)
        ch.basic_consume(callback, queue=qname)
 
        pika.asyncore_loop()
        print 'Close reason:', conn.connection_close
 

src/a/m/amqp-demo-HEAD/demo_receive.py   amqp-demo(Download)
 
ch.basic_consume(handle_delivery, queue = qname)
pika.asyncore_loop()
print 'Close reason:', conn.connection_close