I just started with TCA, so forgive me if there is a easy solution i failed to see.

I have a Service, that downloads the latest datapoints and returns it as an AsyncSequence. I want to display 4 datapoints in my feature simultaneously, so when i refresh all, i .merge Effects like this:

[...]
  Reduce { state, action in
      switch action {
      case .refresh:
        return .merge(
          updateData(1),
          updateData(2),
          updateData(3),
        )
      }
  }
[...]
private func updateData(_ src: Int) -> Effect<Action> {
    return .run { send in
        let asyncStream = service.fetch(src)
        for await result in stream {
            await send(.update(src: src, with: result)))
        }
    }
}

This works fine and the fetches are simultaneous, but testing doesn't work when i try it like this:

[...]
testStore.send(.refresh)
testStore.receive(.update(1)) { $0.point1 = mockedPoint }
testStore.receive(.update(2)) { $0.point2 = mockedPoint }
testStore.receive(.update(3)) { $0.point3 = mockedPoint }
[...]

• When checking the Effects the sequence is always changing, so it fails at random whenever one mocked execution is resolved a nanosecond faster.
• When checking the State the effects of other Effects are sometimes taken into account, so that depending on the runing device, i sometimes get the last state in the first .receive(.update(..)) and all following .receive(.update(..)) calls don't have any state changes

Currently this test succeeds on my system, but it doesn't feel like it should and like it could collapse at any moment:

[...]
testStore.send(.refresh)
testStore.receive(.update(3)) { 
    $0.point1 = mockedPoint
    $0.point2 = mockedPoint
    $0.point3 = mockedPoint
}
testStore.receive(.update(1))
testStore.receive(.update(2))
[...]

Is there a good method to testing parallel effects / actions in TCA?