subscribeStream method
Implementation
FieldSubscription<T> subscribeStream(void onData(T? event),
{Function? onError,
void onDone()?,
bool cancelOnError = false,
bool current = true}) {
// ignore: cancel_subscriptions
final subscription = _stream.stream.listen(
onData,
);
if (value != null && current) {
onData(value);
}
return _addSub<T>(
subscription,
onError: onError,
onDone: onDone,
cancelOnError: cancelOnError,
);
}