close method

Implementation

@override
Future<void> close() async {
  if (_closed) return;
  _closed = true;
  await _subscription?.cancel();
  _subscription = null;
  if (!_pendingController.isClosed) {
    await _pendingController.close();
  }
}