From 5cfd335ed35d6b97a470e81ebc531829f21f279c Mon Sep 17 00:00:00 2001 From: Multu <40861944+Multu@users.noreply.github.com> Date: Wed, 31 Jan 2024 17:32:55 +0300 Subject: [PATCH] fix: _buffer use javascript syntax (#63) --- src/peerjs/dataconnection.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/peerjs/dataconnection.py b/src/peerjs/dataconnection.py index 2cbd9a4..e9ac9ee 100644 --- a/src/peerjs/dataconnection.py +++ b/src/peerjs/dataconnection.py @@ -73,7 +73,7 @@ def _apply_options( self._negotiator: Negotiator = None self.stringify = lambda data: json.dumps(data) self.parse = lambda jsn: json.loads(jsn) - self._buffer: [] + self._buffer = [] self._bufferSize = 0 self._buffering = False self._chunkedData = {} @@ -287,8 +287,8 @@ async def send(self, data, chunked: bool = False) -> None: async def _bufferedSend(self, msg: any) -> None: if self._buffering or not await self._trySend(msg): - self._buffer.push(msg) - self._bufferSize = self._buffer.length + self._buffer.append(msg) + self._bufferSize = len(self._buffer) async def _trySend(self, msg) -> bool: """Return true if the send succeeds.""" @@ -320,14 +320,14 @@ def _tryBuffer(self) -> None: """Try to send the first message in the buffer.""" if not self.open: return - if self._buffer.length == 0: + if len(self._buffer) == 0: return msg = self._buffer[0] if self._trySend(msg): - self._buffer.shift() - self._bufferSize = self._buffer.length + self._buffer.pop() + self._bufferSize = len(self._buffer) self._tryBuffer() # def _sendChunks(self, blob: Blob) -> None: