chore(spanner): fix tests

google-cloud-spanner/src/test/java/com/google/cloud/spanner/AsyncRunnerTest.java

@@ -201,11 +201,10 @@ public void asyncRunnerUpdateAbortedWithoutGettingResult() throws Exception {
             executor);
     assertThat(result.get()).isNull();
     assertThat(attempt.get()).isEqualTo(2);
-    if (isMultiplexedSessionsEnabled()) {
+    if (isMultiplexedSessionsEnabledForRW()) {
       assertThat(mockSpanner.getRequestTypes())
           .containsExactly(
               CreateSessionRequest.class,
-              BatchCreateSessionsRequest.class,
               ExecuteSqlRequest.class,
               // The retry will use an explicit BeginTransaction RPC because the first statement of
               // the transaction did not return a transaction id during the initial attempt.
@@ -260,12 +259,12 @@ public void asyncRunnerWaitsUntilAsyncUpdateHasFinished() throws Exception {
             },
             executor);
     res.get();
-    if (isMultiplexedSessionsEnabled()) {
+    if (isMultiplexedSessionsEnabledForRW()) {
       // The mock server could have received a CreateSession request for a multiplexed session, but
       // it could also be that that request has not yet reached the server.
       assertThat(mockSpanner.getRequestTypes())
           .containsAtLeast(
-              BatchCreateSessionsRequest.class, ExecuteSqlRequest.class, CommitRequest.class);
+              CreateSessionRequest.class, ExecuteSqlRequest.class, CommitRequest.class);
     } else {
       assertThat(mockSpanner.getRequestTypes())
           .containsExactly(
@@ -404,11 +403,10 @@ public void asyncRunnerBatchUpdateAbortedWithoutGettingResult() throws Exception
             executor);
     assertThat(result.get()).isNull();
     assertThat(attempt.get()).isEqualTo(2);
-    if (isMultiplexedSessionsEnabled()) {
+    if (isMultiplexedSessionsEnabledForRW()) {
       assertThat(mockSpanner.getRequestTypes())
           .containsExactly(
               CreateSessionRequest.class,
-              BatchCreateSessionsRequest.class,
               ExecuteSqlRequest.class,
               ExecuteBatchDmlRequest.class,
               CommitRequest.class,
@@ -463,11 +461,10 @@ public void asyncRunnerWaitsUntilAsyncBatchUpdateHasFinished() throws Exception
             },
             executor);
     res.get();
-    if (isMultiplexedSessionsEnabled()) {
+    if (isMultiplexedSessionsEnabledForRW()) {
       assertThat(mockSpanner.getRequestTypes())
           .containsExactly(
               CreateSessionRequest.class,
-              BatchCreateSessionsRequest.class,
               ExecuteBatchDmlRequest.class,
               CommitRequest.class);
     } else {
@@ -576,4 +573,11 @@ private boolean isMultiplexedSessionsEnabled() {
     }
     return spanner.getOptions().getSessionPoolOptions().getUseMultiplexedSession();
   }
+
+  private boolean isMultiplexedSessionsEnabledForRW() {
+    if (spanner.getOptions() == null || spanner.getOptions().getSessionPoolOptions() == null) {
+      return false;
+    }
+    return spanner.getOptions().getSessionPoolOptions().getUseMultiplexedSessionForRW();
+  }
 }