RxCommandStream<TParam, TResult> constructor
RxCommandStream<TParam, TResult> ()
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);
}