in lib/src/async_message_grouper.dart [123:129]
Future cancel() { if (!_done.isCompleted) { _done.complete(null); return _inputQueue.cancel()!; } return done; }