Skip to content

Commit 1b1d9b2

Browse files
authored
Don't throw if rfile is closed (#28)
* Don't throw if rfile is closed * Update streams.py * Retrigger CI
1 parent 72c370f commit 1b1d9b2

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

pyls_jsonrpc/streams.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,13 @@ def listen(self, message_consumer):
2222
message_consumer (fn): function that is passed each message as it is read off the socket.
2323
"""
2424
while not self._rfile.closed:
25-
request_str = self._read_message()
25+
try:
26+
request_str = self._read_message()
27+
except ValueError:
28+
if self._rfile.closed:
29+
return
30+
else:
31+
log.exception("Failed to read from rfile")
2632

2733
if request_str is None:
2834
break

0 commit comments

Comments
 (0)