transformEvents method
Stream<BlopEvent<RemoteModel<T> > >
transformEvents(
- Stream<
BlopEvent< events,RemoteModel< >T> > - Stream<
BlopEvent< mapper(RemoteModel< >T> >- BlopEvent<
RemoteModel< eventT> >
- BlopEvent<
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)));
}