start method

  1. @override
Stream<Resource<R>> start(
  1. P? param
)
override

Implementation

@override
Stream<Resource<R>> start(P? param) async* {
  try {
    yield* doTask(param)
        .map((event) => map(event))
        .onErrorReturnWith((Object error, stackTrace) {
      return ResourceError(failure: error.asFailure());
    }).startWith(const Resource.loading());
  } catch (e, s) {
    logger.e("$this Error", error: e, stackTrace: s);
    yield ResourceError(failure: e.asFailure());
  }
}