TestStore and Combine ZIP

[3a4oT]

Hello, I'm kind of stuck with testing of action which wraps Publishers.Zip

I have:

    func getFooBarOptions() -> AnyPublisher<MyResponse, Never> {
        Publishers.Zip(self.apiClient.networkReq(SomeEndpoint.path)
                        .map({$0.data})
                        .decode(as: IdentifiedArrayOf<Foo>.self)
                        .mapError { error in
                            error as NSError
                        }
                        .catchToEffect()
                        .cancellable(id: FooCancelToken())
                        .eraseToAnyPublisher(),
                       self.apiClient.networkReq(OtherEndpoint.otherPath)
                        .map({$0.data})
                        .decode(as: IdentifiedArrayOf<Bar>.self)
                        .mapError { error in
                            error as NSError
                        }
                        .catchToEffect()
                        .cancellable(id: BarCancelToken())
                        .eraseToAnyPublisher())
            .map { arg in
                let mapped = MyResponse(fooResponse: arg.0,
                                                 barResponse: arg.1)
                return mapped
            }.eraseToAnyPublisher()
    }

Then on reducer I use it like:

        case .loadData:
            state.isActivityIndicatorShowed = true
            return env.getFooBarOptions()
                .receive(on: env.mainQueue)
                .catchToEffect()
                .cancellable(id: BuchLoadCancelToken(), cancelInFlight: true)
                .map(MyAction.butchNetworkResponse)
        case let .butchNetworkResponse(.success(args)):
            state.isActivityIndicatorShowed = false
            return .merge(.init(value: MyAction.fooResponse(args.fooResponse)),
                          .init(value: MyAction.barResponse(args.barResponse)))

On my tests, I want to verify the chain of effects but I can not understand why TestStore doesn't track all action:

    func testLoadDataOnViewWillAppear() {
        store.assert(.send(.onRootViewAppear),
                     .receive(.loadData, { state in
                        state.isActivityIndicatorShowed = true
                     }), .do {
                        Self.testScheduler.advance(by: 1)
                     })
    }

My expectation is that this test should fail because the butchNetworkResponse action is missed, but it passed successfully, and the code under Publishers.Zip was never executed.

[mbrandonw]

Hi @3a4oT, it's hard to know what is going on without more code. Are you able to reduce this to an example that we can run to reproduce?

Or can you provide more of the surrounding context of the code? For example, how is the environment constructed for the test?