docs: def abort(self):
          """
          Immediately close the stream, without sending remaining buffers or
          performing a proper shutdown.
          """
          if self._state == _State.CLOSED:
              self._invalid_state("abort() called")
              return
  
          self._force_close(None)