`emit.forEach` with `restartable` transformer emits both events

[vasilich6107]

Description
Hi @felangel . I'm working with restartable transformer.
Here is example with test

https://github.com/vasilich6107/bloc_stream_restartable

Steps To Reproduce
Run tests from test folder.

Expected Behavior
I'm making 2 async requests using variables1 and variables2.
On mock level I do some delays to emulate async requests.

With restartable transformer I assume that second bloc.run(variables2); will cancel previous handler.
As a result I expect

expect: () => [
        isA<QueryStateLoading<Map<String, dynamic>>>(),
        isA<QueryStateLoaded<Map<String, dynamic>>>(),
      ],

In reality I'm getting one loading state and 2 loaded.

Screenshots

[vasilich6107]

I've also checked this issue with no luck
#3349 (comment)

[vasilich6107]

Hi @felangel
Could you help with this issue

[vasilich6107]

Could anyone clarify the correctness of my approach?

[vasilich6107]

Good morning @felangel
Could you take a look