File tree Expand file tree Collapse file tree
google-cloud-clients/google-cloud-firestore/src/main/java/com/google/cloud/firestore Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2929import com .google .cloud .firestore .spi .v1 .FirestoreRpc ;
3030import com .google .common .base .Preconditions ;
3131import com .google .common .collect .ImmutableMap ;
32+ import com .google .common .util .concurrent .MoreExecutors ;
3233import com .google .firestore .v1 .BatchGetDocumentsRequest ;
3334import com .google .firestore .v1 .BatchGetDocumentsResponse ;
3435import com .google .firestore .v1 .DatabaseRootName ;
@@ -339,9 +340,11 @@ public void onSuccess(List<WriteResult> writeResults) {
339340 span .end ();
340341 resultFuture .set (userResult );
341342 }
342- });
343+ },
344+ MoreExecutors .directExecutor ());
343345 }
344- });
346+ },
347+ MoreExecutors .directExecutor ());
345348 }
346349
347350 private SettableApiFuture <T > invokeUserCallback () {
@@ -396,12 +399,14 @@ public void onFailure(Throwable throwable) {
396399 public void onSuccess (Void ignored ) {
397400 resultFuture .setException (throwable );
398401 }
399- });
402+ },
403+ MoreExecutors .directExecutor ());
400404 } else {
401405 resultFuture .setException (throwable );
402406 }
403407 }
404- });
408+ },
409+ MoreExecutors .directExecutor ());
405410 }
406411
407412 /** Returns whether the user has opted into receiving dates as com.google.cloud.Timestamp. */
Original file line number Diff line number Diff line change @@ -85,7 +85,7 @@ public GrpcFirestoreRpc(final FirestoreOptions options) throws IOException {
8585 || NoCredentials .getInstance ().equals (options .getCredentials ())) {
8686 ManagedChannel managedChannel =
8787 ManagedChannelBuilder .forTarget (options .getHost ())
88- .usePlaintext (true )
88+ .usePlaintext ()
8989 .executor (executor )
9090 .build ();
9191 TransportChannel transportChannel = GrpcTransportChannel .create (managedChannel );
You can’t perform that action at this time.
0 commit comments