pubsublite/internal/wire: TestRoutingPublisherUnloadIdlePublisher failed

Note: #7342 was also for this test, but it was closed more than 10 days ago. So, I didn't mark it flaky.

commit: 3953c5300508ca9cae9c1da15ab7c127bbeb2fa6 buildURL: Build Status, Sponge status: failed

Test output

    verifier.go:226: call(2): did not receive expected request:
        [*pubsublitepb.PublishRequest] message_publish_request:{messages:{key:"baz" data:"2"} first_sequence_number:1}
    verifier.go:226: call(3): did not receive expected request:
        [*pubsublitepb.PublishRequest] message_publish_request:{messages:{key:"baz" data:"3"} first_sequence_number:2}
    verifier.go:226: call(4): did not receive expected request:
        [*pubsublitepb.PublishRequest] message_publish_request:{messages:{key:"baz" data:"4"} first_sequence_number:3}
    verifier.go:226: call(5): did not receive expected request:
        [*pubsublitepb.PublishRequest] message_publish_request:{messages:{key:"baz" data:"5"} first_sequence_number:4}
    verifier.go:226: call(6): did not receive expected request:
        [*pubsublitepb.PublishRequest] message_publish_request:{messages:{key:"baz" data:"6"} first_sequence_number:5}
    verifier.go:257: unexpected stream index 1 for key publish:projects/123456/locations/us-central1-b/topics/my-topic:0
    publish_batcher_test.go:71: Publish("2") error: (rpc error: code = FailedPrecondition desc = mockserver: got unexpected stream connection), want: partition=0,offset=11
    publish_batcher_test.go:71: Publish("3") error: (pubsublite: service has stopped or is stopping), want: partition=0,offset=12
    publish_batcher_test.go:71: Publish("4") error: (pubsublite: service has stopped or is stopping), want: partition=0,offset=13
    publish_batcher_test.go:71: Publish("5") error: (pubsublite: service has stopped or is stopping), want: partition=0,offset=14
    publish_batcher_test.go:71: Publish("6") error: (pubsublite: service has stopped or is stopping), want: partition=0,offset=15
    publish_batcher_test.go:71: Publish("b") error: (pubsublite: service has stopped or is stopping), want: partition=1,offset=22
    publisher_test.go:619: Stop() got err: (publisher(projects/123456/locations/us-central1-b/topics/my-topic/partitions/0): rpc error: code = FailedPrecondition desc = mockserver: got unexpected stream connection)
    verifier.go:226: call(0): did not receive expected request:
        [*pubsublitepb.PublishRequest] initial_request:{topic:"projects/123456/locations/us-central1-b/topics/my-topic" partition:1 client_id:"publisher"}
    verifier.go:226: call(1): did not receive expected request:
        [*pubsublitepb.PublishRequest] message_publish_request:{messages:{key:"bar" data:"b"} first_sequence_number:1}

googleapis / google-cloud-go

pubsublite/internal/wire: TestRoutingPublisherUnloadIdlePublisher failed #7854