Extension on Behavior Subject to add data or error safely without explicitly checking for subject close

behavior_subject_extension.dart

import 'package:rxdart/subjects.dart';

extension BehaviorSubjectX<T> on BehaviorSubject<T> {
  /// Add [data] only when stream is not closed
  ///
  /// No data is added if stream is closed
  void addDataSafely(T data) {
    if (!isClosed) {
      return sink.add(data);
    } else {
      print('Adding data failed: Stream already closed!');
    }
  }

  /// Add [error] only when stream is not closed
  ///
  /// No data is added if stream is closed
  void addErrorSafely(error) {
    if (!isClosed) {
      return sink.addError(error);
    } else {
      print('Adding error failed: Stream already closed!');
    }
  }
}