markUnsubscribed method

void markUnsubscribed()

Marks this subscription as unsubscribed

Implementation

void markUnsubscribed() {
  if (!_isActive) return;

  _isActive = false;
  _unsubscribeController.add(null);
  _messageController.close();
  _unsubscribeController.close();
}