clear method

  1. @override
void clear()

Discards every buffered event.

Implementation

@override
void clear() {
  final end = _end;
  _events.clear();
  _base = end;
  for (final reader in _readers) {
    reader._cursor = end;
  }
  _retainedEnds.clear();
}