createForwardingSubject<R> method

  1. @override
Subject<R> createForwardingSubject<R>({
  1. void onListen()?,
  2. void onCancel()?,
  3. bool sync = false,
})

Implementation

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