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

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

src/s/l/sleipnir.transport-0.1.0/src/sleipnir/transport/adapters/pyside.py   sleipnir.transport(Download)
#Pika requirements
from pika.reconnection_strategies import ReconnectionStrategy
from pika.adapters.base_connection import BaseConnection, READ, WRITE
 
 
    def _adapter_connect(self):
        # Connect (blockignly!) to the server
        BaseConnection._adapter_connect(self)
        self.event_state |= WRITE
        # Setup the IOLoop
        if event_state & READ:
            self.poller.reader.setEnabled(True)
        if event_state & WRITE:
            self.poller.writer.setEnabled(True)