LceStreamExtension<DATA extends Object> extension

Methods

dataNoErrors() → Stream<DATA>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Model's data stream with state information dropped. No error events DATA Source model data type

dataWithEmptyErrors() → Stream<DATA>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Model's data stream with state information dropped. Emits error event on upstream error state when upstream has no data DATA Source model data type

dataWithErrors() → Stream<DATA>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Model's data stream with state information dropped. Emits error event on upstream error state DATA Source model data type

errorIf(bool predicate(LceError<DATA> error)) → Stream<LceState<DATA>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Emits error event when state is LceError and predicate returns true

errorOnEmptyError() → Stream<LceState<DATA>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Emits error on every LceError with empty data

errorOnError() → Stream<LceState<DATA>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Emits error on every LceError

errorToLce([DATA? errorData(Object error)?]) → Stream<LceState<DATA>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Maps an upstream error to LceError errorData Evaluates data for error state

flatMapSingleData<DATA_2 extends Object>(Future<DATA_2> mapper(DATA data)) → Stream<LceState<DATA_2>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Maps each DATA to future for DATA_2 and merges back to LceState. If error occurs in mapper emits LceError. Example: load some DATA_2 from server using original DATA as a parameter. DATA_2 Resulting data type mapper Data mapper

getData([bool errorPredicate(LceError<DATA> error)?]) → Stream<DATA>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Returns model's data stream dropping state information DATA Source model data type errorPredicate A predicate to check error state. If predicate returns true, the stream emits error event

onEmptyLoadingReturn(LceState<DATA> block(LceLoading<DATA> loading)) → Stream<LceState<DATA>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Substitutes LceLoading with empty data with state produced by block block transformation block

onEmptyLoadingReturnData(DATA block()) → Stream<LceState<DATA>>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Substitutes LceLoading empty data with data produced by block block Item creation block

validData([bool errorPredicate(LceError<DATA> error)?]) → Stream<DATA>

Available on Stream<LceState<DATA>>, provided by the LceStreamExtension extension

Model's valid data stream with state information dropped. DATA Source model data type errorPredicate A predicate to check error state. If predicate returns true, the stream emits error event