code: def reconnect(self):
          '''Connected the stream if needed.
  
          Coroutine.
          '''
          if self._connection.closed():
              self._connection.reset()
  
              yield from self._connection.connect(f reconnect(self):
          '''Connected the stream if needed.
  
          Coroutine.
          '''
          if self._connection.closed():
              self._connection.reset()
  
              yield from self._connection.connect()
docs: Connected the stream if needed.
  
          Coroutine.