purgeExpired method

void purgeExpired()

Removes messages that have exceeded their messageTimeout.

Implementation

void purgeExpired() {
  _queue.removeWhere((m) => m.isExpired);
}