cancel method

  1. @override
Future cancel()
override

Implementation

@override
Future cancel() async {
  await _outputStream.close();
  await _messageGrouper.cancel();
}