def _create_io_thread(self):
        return io.IO(name='%s-io' % self._name,
                     kwargs={'events': self._events,
                             'exceptions': self._exceptions,
                             'connection_args': self._args,
                             'write_queue': self._write_queue})
Create the IO thread and the objects it uses for communication.
dataset/ETHPy150Open gmr/rabbitpy/rabbitpy/connection.py/Connection._create_io_thread