@@ -898,49 +898,29 @@ public void asyncTransactionManagerBatchUpdateAbortedWithoutGettingResult() thro
898898 }
899899 }
900900 assertThat (attempt .get ()).isEqualTo (2 );
901- Iterable <Class <? extends AbstractMessage >> requests = mockSpanner .getRequestTypes ();
901+ List <Class <? extends AbstractMessage >> requests = mockSpanner .getRequestTypes ();
902+ // Remove the CreateSession requests for multiplexed sessions, as those are not relevant for
903+ // this test.
904+ requests .removeIf (request -> request == CreateSessionRequest .class );
902905 int size = Iterables .size (requests );
903906 assertThat (size ).isIn (Range .closed (5 , 6 ));
904- if (isMultiplexedSessionsEnabled ()) {
905- if (size == 6 ) {
906- assertThat (requests )
907- .containsExactly (
908- CreateSessionRequest .class ,
909- BatchCreateSessionsRequest .class ,
910- ExecuteBatchDmlRequest .class ,
911- BeginTransactionRequest .class ,
912- ExecuteBatchDmlRequest .class ,
913- CommitRequest .class );
914- } else {
915- assertThat (requests )
916- .containsExactly (
917- CreateSessionRequest .class ,
918- BatchCreateSessionsRequest .class ,
919- ExecuteBatchDmlRequest .class ,
920- CommitRequest .class ,
921- BeginTransactionRequest .class ,
922- ExecuteBatchDmlRequest .class ,
923- CommitRequest .class );
924- }
907+ if (size == 5 ) {
908+ assertThat (requests )
909+ .containsExactly (
910+ BatchCreateSessionsRequest .class ,
911+ ExecuteBatchDmlRequest .class ,
912+ BeginTransactionRequest .class ,
913+ ExecuteBatchDmlRequest .class ,
914+ CommitRequest .class );
925915 } else {
926- if (size == 5 ) {
927- assertThat (requests )
928- .containsExactly (
929- BatchCreateSessionsRequest .class ,
930- ExecuteBatchDmlRequest .class ,
931- BeginTransactionRequest .class ,
932- ExecuteBatchDmlRequest .class ,
933- CommitRequest .class );
934- } else {
935- assertThat (requests )
936- .containsExactly (
937- BatchCreateSessionsRequest .class ,
938- ExecuteBatchDmlRequest .class ,
939- CommitRequest .class ,
940- BeginTransactionRequest .class ,
941- ExecuteBatchDmlRequest .class ,
942- CommitRequest .class );
943- }
916+ assertThat (requests )
917+ .containsExactly (
918+ BatchCreateSessionsRequest .class ,
919+ ExecuteBatchDmlRequest .class ,
920+ CommitRequest .class ,
921+ BeginTransactionRequest .class ,
922+ ExecuteBatchDmlRequest .class ,
923+ CommitRequest .class );
944924 }
945925 }
946926
0 commit comments