Lines Matching defs:Stream
54 from mod_pywebsocket._stream_hybi import Stream
647 class _LogicalStream(Stream):
648 """Mimics the Stream class. This class interprets multiplexed WebSocket
663 # Physical stream is responsible for masking.
667 Stream.__init__(self, request, stream_options)
753 """Override Stream.send_message."""
772 """Overrides Stream._receive_frame.
774 In addition to call Stream._receive_frame, this method adds the amount
776 We need to do it here because Stream.receive_message() handles
780 opcode, payload, fin, rsv1, rsv2, rsv3 = Stream._receive_frame(self)
791 """Overrides Stream.receive_message."""
793 # Just call Stream.receive_message(), but catch
797 return Stream.receive_message(self)
803 """Overrides Stream._send_closing_handshake."""
813 """Overrides Stream.send_ping"""
822 """Overrides Stream._send_pong"""
829 """Overrides Stream.close_connection."""
837 """Overrides Stream._drain_received_data. Nothing need to be done for
1028 self._logger.debug('Creating logical stream for %d' %
1064 The reader thread reads data from the physical stream, i.e., the
