diff --git a/netconf/base.py b/netconf/base.py index 23f6228..a88127c 100644 --- a/netconf/base.py +++ b/netconf/base.py @@ -183,6 +183,10 @@ def _receive_10(self): break searchfrom = max(0, len(self.rbuffer) - 5) buf = self.stream.recv(self.max_chunk) + if not buf: + if self.debug: + logger.debug("Channel closed: stream is None") + raise ChannelClosed(self) self.rbuffer += buf msg = self.rbuffer[:eomidx]