We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c95c025 commit 1ad30e9Copy full SHA for 1ad30e9
aiohttp/_websocket/writer.py
@@ -11,7 +11,6 @@
11
from ..compression_utils import ZLibCompressor
12
from .helpers import (
13
MASK_LEN,
14
- MSG_SIZE,
15
PACK_CLOSE_CODE,
16
PACK_LEN1,
17
PACK_LEN2,
@@ -135,13 +134,10 @@ async def send_frame(
135
134
mask = PACK_RANDBITS(self.get_random_bits())
136
message = bytearray(message)
137
websocket_mask(mask, message)
138
- self.transport.write(header + mask + message)
+ self.transport.writelines((header, mask, message))
139
self._output_size += MASK_LEN
140
- elif msg_length > MSG_SIZE:
141
- self.transport.write(header)
142
- self.transport.write(message)
143
else:
144
- self.transport.write(header + message)
+ self.transport.write((header, message))
145
146
self._output_size += header_len + msg_length
147
0 commit comments