Lines Matching defs:Stream
55 from mod_pywebsocket._stream_hybi import Stream
808 class _LogicalStream(Stream):
809 """Mimics the Stream class. This class interprets multiplexed WebSocket
823 # Physical stream is responsible for masking.
825 Stream.__init__(self, request, stream_options)
957 """Override Stream.send_message."""
988 """Overrides Stream._receive_frame.
990 In addition to call Stream._receive_frame, this method adds the amount
992 We need to do it here because Stream.receive_message() handles
996 opcode, payload, fin, rsv1, rsv2, rsv3 = Stream._receive_frame(self)
1010 """Overrides Stream._get_message_from_frame.
1025 """Overrides Stream.receive_message."""
1027 # Just call Stream.receive_message(), but catch
1031 return Stream.receive_message(self)
1037 """Overrides Stream._send_closing_handshake."""
1047 """Overrides Stream.send_ping"""
1056 """Overrides Stream._send_pong"""
1063 """Overrides Stream.close_connection."""
1320 self._logger.debug('Creating logical stream for %d' %
1406 The reader thread reads data from the physical stream, i.e., the
