reset unsub to None on timeout (#22404)

This commit is contained in:
Jason Hunter 2019-03-26 03:39:09 -04:00 committed by Paulus Schoutsen
parent fac214828d
commit 8a6d9cc0e4

View File

@ -128,6 +128,7 @@ class StreamOutput:
@callback @callback
def _timeout(self, _now=None): def _timeout(self, _now=None):
"""Handle stream timeout.""" """Handle stream timeout."""
self._unsub = None
if self._stream.keepalive: if self._stream.keepalive:
self.idle = True self.idle = True
self._stream.check_idle() self._stream.check_idle()