subject property
Implementation
StreamController<T> get subject {
if (_controller == null) {
_controller = StreamController<T>.broadcast(
onListen: () {
if (!isDisposed) {
_removeStreamListener ??= addListener(_streamListener);
}
},
onCancel: _detachStreamListener,
);
if (isDisposed) _controller!.close();
}
return _controller!;
}