src/roslibpy/comm/comm_autobahn.py
def run(self):
        """Kick-starts a non-blocking event loop.

        This implementation starts the Twisted Reactor
        on a separate thread to avoid blocking."""

        if reactor.running:
            LOGGER.warn('Twisted reactor is already running')
            return

        self._thread = threading.Thread(target=reactor.run, args=(False,))
        self._thread.daemon = True
        self._thread.start()
Kick-starts a non-blocking event loop.

        This implementation starts the Twisted Reactor
        on a separate thread to avoid blocking.
Kick-starts a non-blocking event loop.
This implementation starts the Twisted Reactor
on a separate thread to avoid blocking.
Kick - starts a non - blocking event loop . This implementation starts the Twisted Reactor on a separate thread to avoid blocking .
def run(self):
        if reactor.running:
            LOGGER.warn('Twisted reactor is already running')
            return
        self._thread = threading.Thread(target=reactor.run, args=(False,))
        self._thread.daemon = True
        self._thread.start()
def run ( self ) : if reactor . running : LOGGER . warn ( 'Twisted reactor is already running' ) return self . _thread = threading . Thread ( target = reactor . run , args = ( False , ) ) self . _thread . daemon = True self . _thread . start ( )
Kick-starts a non-blocking event loop.
Kick - starts a non - blocking event loop .
"""Kick-starts a non-blocking event loop.

        This implementation starts the Twisted Reactor
        on a separate thread to avoid blocking."""
self