language-servers/erg
1
0
Fork 0
mirror of https://github.com/erg-lang/erg.git synced 2025-10-01 21:21:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update repl_server.py

Browse source
This commit is contained in:
Shunsuke Shibayama 2023-04-26 23:59:23 +09:00
parent 2c5ba704f8
commit 03a30a450a
1 changed files with 2 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/scripts/repl_server.py
View file

@ -26,16 +26,10 @@ class MessageStream:
def recv_msg(self): def recv_msg(self):
self._read_buf.clear() self._read_buf.clear()
# requires at least 3 bytes as metadata self._read_buf.extend(self.socket.recv(3))
while len(self._read_buf) < 3:
self._read_buf.extend(self.socket.recv(1024))
inst = int.from_bytes(self._read_buf[:1], 'big') inst = int.from_bytes(self._read_buf[:1], 'big')
data_len = int.from_bytes(self._read_buf[1:3], 'big') data_len = int.from_bytes(self._read_buf[1:3], 'big')
self._read_buf.extend(self.socket.recv(data_len))
# until all data has been read
while len(self._read_buf) < 3 + data_len:
self._read_buf.extend(self.socket.recv(1024))
return (inst, self._read_buf[3:].decode()) return (inst, self._read_buf[3:].decode())