cancel method

Future<void> cancel()

Dispose the consumer and cancel the underlying stream.

Implementation

Future<void> cancel() async {
  await _stream.cancel();
}