cancel method

Future<void> cancel()

Cancels the current stream subscription.

Implementation

Future<void> cancel() async {
  return MinixErrorHandler.safeExecuteAsync(() async {
    await _subscription?.cancel();
    _subscription = null;
    if (!isDisposed && _state.value != StreamState.closed) {
      _state.value = StreamState.idle;
    }
  }, context: 'StreamObservable.cancel');
}