@@ -119,7 +119,7 @@ private void verifyBuilder(
119119 assertThat (builder .getAppProfileId ()).isEqualTo (appProfileId );
120120 assertThat (builder .getEndpoint ()).isEqualTo (endpoint );
121121 assertThat (builder .getCredentialsProvider ()).isEqualTo (credentialsProvider );
122- assertThat (builder .getStreamWatchdogProvider ()).isSameAs (watchdogProvider );
122+ assertThat (builder .getStreamWatchdogProvider ()).isSameInstanceAs (watchdogProvider );
123123 assertThat (builder .getStreamWatchdogCheckInterval ()).isEqualTo (watchdogInterval );
124124 }
125125
@@ -137,7 +137,7 @@ private void verifySettings(
137137 assertThat (settings .getAppProfileId ()).isEqualTo (appProfileId );
138138 assertThat (settings .getEndpoint ()).isEqualTo (endpoint );
139139 assertThat (settings .getCredentialsProvider ()).isEqualTo (credentialsProvider );
140- assertThat (settings .getStreamWatchdogProvider ()).isSameAs (watchdogProvider );
140+ assertThat (settings .getStreamWatchdogProvider ()).isSameInstanceAs (watchdogProvider );
141141 assertThat (settings .getStreamWatchdogCheckInterval ()).isEqualTo (watchdogInterval );
142142 }
143143
@@ -189,19 +189,19 @@ public void readRowsIsNotLostTest() {
189189
190190 assertThat (builder .readRowsSettings ().getIdleTimeout ()).isEqualTo (Duration .ofMinutes (5 ));
191191 assertThat (builder .readRowsSettings ().getRetryableCodes ())
192- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
192+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
193193 assertThat (builder .readRowsSettings ().getRetrySettings ()).isEqualTo (retrySettings );
194194
195195 assertThat (builder .build ().readRowsSettings ().getIdleTimeout ())
196196 .isEqualTo (Duration .ofMinutes (5 ));
197197 assertThat (builder .build ().readRowsSettings ().getRetryableCodes ())
198- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
198+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
199199 assertThat (builder .build ().readRowsSettings ().getRetrySettings ()).isEqualTo (retrySettings );
200200
201201 assertThat (builder .build ().toBuilder ().readRowsSettings ().getIdleTimeout ())
202202 .isEqualTo (Duration .ofMinutes (5 ));
203203 assertThat (builder .build ().toBuilder ().readRowsSettings ().getRetryableCodes ())
204- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
204+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
205205 assertThat (builder .build ().toBuilder ().readRowsSettings ().getRetrySettings ())
206206 .isEqualTo (retrySettings );
207207 }
@@ -241,15 +241,15 @@ public void readRowIsNotLostTest() {
241241 builder .readRowsSettings ().setRetryableCodes (Code .ABORTED , Code .DEADLINE_EXCEEDED );
242242
243243 assertThat (builder .readRowSettings ().getRetryableCodes ())
244- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
244+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
245245 assertThat (builder .readRowSettings ().getRetrySettings ()).isEqualTo (retrySettings );
246246
247247 assertThat (builder .build ().readRowSettings ().getRetryableCodes ())
248- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
248+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
249249 assertThat (builder .build ().readRowSettings ().getRetrySettings ()).isEqualTo (retrySettings );
250250
251251 assertThat (builder .build ().toBuilder ().readRowSettings ().getRetryableCodes ())
252- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
252+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
253253 assertThat (builder .build ().toBuilder ().readRowSettings ().getRetrySettings ())
254254 .isEqualTo (retrySettings );
255255 }
@@ -319,15 +319,15 @@ public void sampleRowKeysSettingsAreNotLostTest() {
319319 .build ();
320320
321321 assertThat (builder .sampleRowKeysSettings ().getRetryableCodes ())
322- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
322+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
323323 assertThat (builder .sampleRowKeysSettings ().getRetrySettings ()).isEqualTo (retrySettings );
324324
325325 assertThat (builder .build ().sampleRowKeysSettings ().getRetryableCodes ())
326- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
326+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
327327 assertThat (builder .build ().sampleRowKeysSettings ().getRetrySettings ()).isEqualTo (retrySettings );
328328
329329 assertThat (builder .build ().toBuilder ().sampleRowKeysSettings ().getRetryableCodes ())
330- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
330+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
331331 assertThat (builder .build ().toBuilder ().sampleRowKeysSettings ().getRetrySettings ())
332332 .isEqualTo (retrySettings );
333333 }
@@ -366,15 +366,15 @@ public void mutateRowSettingsAreNotLostTest() {
366366 .build ();
367367
368368 assertThat (builder .mutateRowSettings ().getRetryableCodes ())
369- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
369+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
370370 assertThat (builder .mutateRowSettings ().getRetrySettings ()).isEqualTo (retrySettings );
371371
372372 assertThat (builder .build ().mutateRowSettings ().getRetryableCodes ())
373- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
373+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
374374 assertThat (builder .build ().mutateRowSettings ().getRetrySettings ()).isEqualTo (retrySettings );
375375
376376 assertThat (builder .build ().toBuilder ().mutateRowSettings ().getRetryableCodes ())
377- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
377+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
378378 assertThat (builder .build ().toBuilder ().mutateRowSettings ().getRetrySettings ())
379379 .isEqualTo (retrySettings );
380380 }
@@ -416,23 +416,24 @@ public void bulkMutateRowsSettingsAreNotLostTest() {
416416 .build ();
417417
418418 assertThat (builder .bulkMutateRowsSettings ().getRetryableCodes ())
419- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
419+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
420420 assertThat (builder .bulkMutateRowsSettings ().getRetrySettings ()).isEqualTo (retrySettings );
421- assertThat (builder .bulkMutateRowsSettings ().getBatchingSettings ()).isSameAs (batchingSettings );
421+ assertThat (builder .bulkMutateRowsSettings ().getBatchingSettings ())
422+ .isSameInstanceAs (batchingSettings );
422423
423424 assertThat (builder .build ().bulkMutateRowsSettings ().getRetryableCodes ())
424- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
425+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
425426 assertThat (builder .build ().bulkMutateRowsSettings ().getRetrySettings ())
426427 .isEqualTo (retrySettings );
427428 assertThat (builder .build ().bulkMutateRowsSettings ().getBatchingSettings ())
428- .isSameAs (batchingSettings );
429+ .isSameInstanceAs (batchingSettings );
429430
430431 assertThat (builder .build ().toBuilder ().bulkMutateRowsSettings ().getRetryableCodes ())
431- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
432+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
432433 assertThat (builder .build ().toBuilder ().bulkMutateRowsSettings ().getRetrySettings ())
433434 .isEqualTo (retrySettings );
434435 assertThat (builder .build ().toBuilder ().bulkMutateRowsSettings ().getBatchingSettings ())
435- .isSameAs (batchingSettings );
436+ .isSameInstanceAs (batchingSettings );
436437 }
437438
438439 @ Test
@@ -475,18 +476,19 @@ public void checkAndMutateRowSettingsAreNotLostTest() {
475476 .build ();
476477
477478 assertThat (builder .checkAndMutateRowSettings ().getRetryableCodes ())
478- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
479- assertThat (builder .checkAndMutateRowSettings ().getRetrySettings ()).isSameAs (retrySettings );
479+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
480+ assertThat (builder .checkAndMutateRowSettings ().getRetrySettings ())
481+ .isSameInstanceAs (retrySettings );
480482
481483 assertThat (builder .build ().checkAndMutateRowSettings ().getRetryableCodes ())
482- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
484+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
483485 assertThat (builder .build ().checkAndMutateRowSettings ().getRetrySettings ())
484- .isSameAs (retrySettings );
486+ .isSameInstanceAs (retrySettings );
485487
486488 assertThat (builder .build ().toBuilder ().checkAndMutateRowSettings ().getRetryableCodes ())
487- .containsAllOf (Code .ABORTED , Code .DEADLINE_EXCEEDED );
489+ .containsAtLeast (Code .ABORTED , Code .DEADLINE_EXCEEDED );
488490 assertThat (builder .build ().toBuilder ().checkAndMutateRowSettings ().getRetrySettings ())
489- .isSameAs (retrySettings );
491+ .isSameInstanceAs (retrySettings );
490492 }
491493
492494 @ Test
@@ -501,7 +503,7 @@ public void checkAndMutateRowSettingsAreSane() {
501503 }
502504
503505 private void verifyRetrySettingAreSane (Set <Code > retryCodes , RetrySettings retrySettings ) {
504- assertThat (retryCodes ).containsAllOf (Code .DEADLINE_EXCEEDED , Code .UNAVAILABLE );
506+ assertThat (retryCodes ).containsAtLeast (Code .DEADLINE_EXCEEDED , Code .UNAVAILABLE );
505507
506508 assertThat (retrySettings .getTotalTimeout ()).isGreaterThan (Duration .ZERO );
507509
0 commit comments