test(pubsublite): fix flaky TestIntegration_PublishSubscribeSinglePar…

…tition (#7098)
googleapis · Nov 23, 2022 · eddaf71 · eddaf71
1 parent 9cb00af
commit eddaf71
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/pubsublite/pscompat/integration_test.go b/pubsublite/pscompat/integration_test.go
@@ -579,6 +579,7 @@ func TestIntegration_PublishSubscribeSinglePartition(t *testing.T) {
 	t.Run("CancelPublisherContext", func(t *testing.T) {
 		cctx, cancel := context.WithCancel(context.Background())
 		publisher := publisherClient(cctx, t, DefaultPublishSettings, topicPath)
+		defer publisher.Stop()
 
 		cancel()
 
@@ -587,10 +588,6 @@ func TestIntegration_PublishSubscribeSinglePartition(t *testing.T) {
 		if _, gotErr := result.Get(ctx); !test.ErrorEqual(gotErr, wantErr) {
 			t.Errorf("Publish() got err: %v, want err: %v", gotErr, wantErr)
 		}
-
-		if gotErr := publisher.Error(); !test.ErrorEqual(gotErr, wantErr) {
-			t.Errorf("Error() got err: %v, want err: %v", gotErr, wantErr)
-		}
 	})
 
 	// Verifies that cancelling the context passed to NewSubscriberClient can shut