webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream Class Reference

Inheritance diagram for webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream:

Public Member Functions
def	__init__ (self, request, stream_options, send_quota, receive_quota)
def	replenish_send_quota (self, send_quota)
def	consume_receive_quota (self, amount)
def	send_message (self, message, end=True, binary=False)
def	receive_message (self)
def	send_ping (self, body='')
def	close_connection (self, code=common.STATUS_NORMAL_CLOSURE, reason='')
def	stop_sending (self)
Public Member Functions inherited from webkitpy.thirdparty.mod_pywebsocket._stream_hybi.Stream
def	__init__ (self, request, options)
def	receive_filtered_frame (self)
def	send_message (self, message, end=True, binary=False)
def	receive_message (self)
def	close_connection (self, code=common.STATUS_NORMAL_CLOSURE, reason='', wait_response=True)
def	send_ping (self, body='')
def	get_last_received_opcode (self)
Public Member Functions inherited from webkitpy.thirdparty.mod_pywebsocket._stream_base.StreamBase
def	__init__ (self, request)
def	receive_bytes (self, length)

Detailed Description

Mimics the Stream class. This class interprets multiplexed WebSocket
frames.

Constructor & Destructor Documentation

__init__()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.__init__	(		self,
			request,
			stream_options,
			send_quota,
			receive_quota
	)

Constructs an instance.

Args:
    request: _LogicalRequest instance.
    stream_options: StreamOptions instance.
    send_quota: Initial send quota.
    receive_quota: Initial receive quota.

Member Function Documentation

close_connection()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.close_connection	(		self,
			code = common.STATUS_NORMAL_CLOSURE,
			reason = ''
	)

Overrides Stream.close_connection.

consume_receive_quota()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.consume_receive_quota	(		self,
			amount
	)

Consumes receive quota. Returns False on failure.

receive_message()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.receive_message

(

self

)

Overrides Stream.receive_message.

replenish_send_quota()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.replenish_send_quota	(		self,
			send_quota
	)

Replenish send quota.

send_message()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.send_message	(		self,
			message,
			end = True,
			binary = False
	)

Override Stream.send_message.

send_ping()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.send_ping	(		self,
			body = ''
	)

Overrides Stream.send_ping

stop_sending()

def webkitpy.thirdparty.mod_pywebsocket.mux._LogicalStream.stop_sending

(

self

)

Stops accepting new send operation (_write_inner_frame).

---

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

• Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/mux.py