niryo_libraries.rosbridge_server.autobahn_websocket.IncomingQueue

class documentation

class IncomingQueue(threading.Thread):

Constructor: IncomingQueue(protocol)

View In Hierarchy

Decouples incoming messages from the Autobahn thread.

This mitigates cases where outgoing messages are blocked by incoming, and vice versa.

Method __init__ Undocumented
Method finish Clear the queue and do not accept further messages.
Method push Undocumented
Method run Undocumented
Instance Variable cond Undocumented
Instance Variable daemon Undocumented
Instance Variable protocol Undocumented
Instance Variable queue Undocumented
Instance Variable _finished Undocumented
def __init__(self, protocol):

Undocumented

def finish(self):

Clear the queue and do not accept further messages.

def push(self, msg):

Undocumented

def run(self):

Undocumented

cond =

Undocumented

daemon: bool =

Undocumented

protocol =

Undocumented

queue =

Undocumented

_finished: bool =

Undocumented