createForwardingSubject<R> method
Implementation
@override
Subject<R> createForwardingSubject<R>({
void Function()? onListen,
void Function()? onCancel,
bool sync = false,
}) =>
PublishSubject<R>(
onListen: onListen,
onCancel: onCancel,
sync: sync,
);