def add_io_state(self, state):
        def add_io_state_callback():
            if not self.iostate & state:
                self.iostate = self.iostate | state
                self.ioloop.update_handler(self.socket, self.iostate)
        self.ioloop.add_callback(add_io_state_callback)
Invoke the `_dispatch_events` method on open channels that requested
dataset/ETHPy150Open ipython/ipython-py3k/IPython/zmq/kernelmanager.py/ZMQSocketChannel.add_io_state--crossover with--dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingConnection._dispatch_channel_events