Inheritance diagram for rosbridge_server.autobahn_websocket.IncomingQueue:

Public Member Functions
def	__init__ (self, protocol)

def	finish (self)

def	push (self, msg)

def	run (self)

Public Attributes
	cond

	daemon

	protocol

	queue

Private Attributes
	_finished

Detailed Description

Decouples incoming messages from the Autobahn thread.

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

Definition at line 70 of file autobahn_websocket.py.

Constructor & Destructor Documentation

◆ init()

def rosbridge_server.autobahn_websocket.IncomingQueue.__init__	(	self,
		protocol
	)

Definition at line 76 of file autobahn_websocket.py.

Member Function Documentation

◆ finish()

def rosbridge_server.autobahn_websocket.IncomingQueue.finish ( self )

Clear the queue and do not accept further messages.

Definition at line 85 of file autobahn_websocket.py.

◆ push()

def rosbridge_server.autobahn_websocket.IncomingQueue.push	(	self,
		msg
	)

Definition at line 93 of file autobahn_websocket.py.

◆ run()

def rosbridge_server.autobahn_websocket.IncomingQueue.run ( self )

Definition at line 98 of file autobahn_websocket.py.

Member Data Documentation

◆ _finished

rosbridge_server.autobahn_websocket.IncomingQueue._finished

private

Definition at line 83 of file autobahn_websocket.py.

◆ cond

rosbridge_server.autobahn_websocket.IncomingQueue.cond

Definition at line 82 of file autobahn_websocket.py.

◆ daemon

rosbridge_server.autobahn_websocket.IncomingQueue.daemon

Definition at line 78 of file autobahn_websocket.py.

◆ protocol

rosbridge_server.autobahn_websocket.IncomingQueue.protocol

Definition at line 80 of file autobahn_websocket.py.

◆ queue

rosbridge_server.autobahn_websocket.IncomingQueue.queue

Definition at line 79 of file autobahn_websocket.py.

The documentation for this class was generated from the following file:

autobahn_websocket.py

Public Member Functions

Public Attributes

Private Attributes