transformEvents method

  1. @override
Stream<BlopEvent<RemoteModel<T>>> transformEvents(
  1. Stream<BlopEvent<RemoteModel<T>>> events,
  2. Stream<BlopEvent<RemoteModel<T>>> mapper(
    1. BlopEvent<RemoteModel<T>> event
    )
)
override

Implementation

@override
Stream<BlopEvent<RemoteModel<T>>> transformEvents(
  Stream<BlopEvent<RemoteModel<T>>> events,
  Stream<BlopEvent<RemoteModel<T>>> Function(
    BlopEvent<RemoteModel<T>> event,
  )
      mapper,
) {
  return super
      .transformEvents(events, mapper)
      .handleError((error, stackTrace) => emit(RemoteModel.error(error)));
}