code: def flush(self):
          
          if not self._emit_partial and len(self._state) != self._state.maxlen:
              self.notify(tuple(self._state))
          self._state.clear()
docs: Flush the queue - this will emit the current queue