RxCommandStream<TParam, TResult> constructor

RxCommandStream<TParam, TResult>(
  1. StreamProvider<TParam, TResult> streamProvider,
  2. Stream<bool>? restriction,
  3. bool emitInitialCommandResult,
  4. bool emitLastResult,
  5. bool emitsLastValueToNewSubscriptions,
  6. TResult? initialLastResult,
  7. bool noResult,
  8. String? debugName,
  9. bool noParamValue,
)

Implementation

factory RxCommandStream(
    StreamProvider<TParam, TResult> streamProvider,
    Stream<bool>? restriction,
    bool emitInitialCommandResult,
    bool emitLastResult,
    bool emitsLastValueToNewSubscriptions,
    TResult? initialLastResult,
    bool noResult,
    String? debugName,
    bool noParamValue) {
  return RxCommandStream._(
      streamProvider,
      emitsLastValueToNewSubscriptions || emitInitialCommandResult
          ? BehaviorSubject<TResult>()
          : PublishSubject<TResult>(),
      restriction,
      emitLastResult,
      emitsLastValueToNewSubscriptions || emitInitialCommandResult,
      emitInitialCommandResult,
      initialLastResult,
      noResult,
      debugName,
      noParamValue);
}