streamOf<T> method

Stream<T> streamOf<T>()

Return dart stream of events with particular name

Implementation

Stream<T> streamOf<T>() {
  if (_isDisposed) {
    throw IllegalStateException(
      message: 'Can\'t call streamOf after dispose.',
    );
  }

  return _streamController.stream
      .where((event) => event is T)
      .map((event) => event as T);
}