flutter bloc not passing through emit.onEach-CodePudding

please ignor the title. i don't know how to make it more clear. from the code below i have two diffrent stream from an api, with the emit.oneach from the new bloc package i am able to emit the streams but the code does not continue after the first stream and i also tried diffrent transformer maybe it would work but it didn't.

on<ProfileEvent>(
      (event, emit) async {
        await event.map(
          loadUser: (e) async {
            emit(state.copyWith(status: ProfileStatus.loading));
            try {
              final user =
                  await _iUserRepository.getUserWithId(userId: e.userid)

               await emit.onEach(
                 _iPostRepository.getPostA(userId: e.userid),
                 onData: (QuerySnapshot<PostA> postA) {
                   add(ProfileEvent.updatePostA(postA.items));
                 },
               );
               await emit.onEach(
                 _iPostRepository.getPostB(userId: e.userid),
                 onData: (QuerySnapshot<PostB> postB) {
                   add(ProfileEvent.updatePostB(postB.items));
                 },
               );

              emit(
                state.copyWith(
                  user: user!,
                  status: ProfileStatus.loaded,
                ),
              );
            } on Failure catch (e) {
              emit(
                state.copyWith(
                  failure: Failure(message: e.message),
                  status: ProfileStatus.error,
                ),
              );
            }
          },
          updatePostA: (e) async {
            emit(state.copyWith(postA: e.postA));
          },
          updatePostB: (e) async {
            emit(state.copyWith(postB: e.postB));
          },
          ...,
          ...,
        );
      },
      //transformer: restartable(),
    );

So as i said at the beginning the program passes through or emit the emit.oneach for postA but does not emit postB and does not event get to the end of the event. its like it just stopped in the first stram which is postA.

N.B: if you are wondering why the format of my bloc is this way thats because of the freezed package. also the querySnapshot comes from the aws amplify.

CodePudding user response：

onEach completes when the event handler is cancelled or when the provided stream has ended.

Meaning that since you await the call, you code will halt there.

CodePudding user response：

What you can do is creating two async methods for each emit.onEach.

Future<void> _listenToStreamA() async =>
    _streamA = await emit.onEach(_iPostRepository.getPostA(userId: e.userid),onData: (QuerySnapshot<PostA> postA) {
                   add(ProfileEvent.updatePostA(postA.items));
                 },
               );

Future<void> _listenToStreamB() async =>
    _streamB =await emit.onEach(_iPostRepository.getPostB(userId: e.userid),onData: (QuerySnapshot<PostB> postB) {
                   add(ProfileEvent.updatePostB(postB.items));
                 },
               );


void close() {
  _streamA.close();
  _streamB.close();
}

Then use it like this:

//...
try {
    final user = await _iUserRepository.getUserWithId(userId: e.userid);
    _listenToStreamA();
    _listenToStreamB();
    //...

And use method ``close()``` to close the streams when disposing the widget.