Skip to content

Commit 9d9404b

Browse files
abhinav-qlogicsduskis
authored andcommitted
FireStore:deprecated warnings removed (#5247)
* deprecated warnings removed * review changes * directExecutor used to remove deprecated warnings
1 parent b2dc157 commit 9d9404b

2 files changed

Lines changed: 10 additions & 5 deletions

File tree

google-cloud-clients/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreImpl.java

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import com.google.cloud.firestore.spi.v1.FirestoreRpc;
3030
import com.google.common.base.Preconditions;
3131
import com.google.common.collect.ImmutableMap;
32+
import com.google.common.util.concurrent.MoreExecutors;
3233
import com.google.firestore.v1.BatchGetDocumentsRequest;
3334
import com.google.firestore.v1.BatchGetDocumentsResponse;
3435
import 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. */

google-cloud-clients/google-cloud-firestore/src/main/java/com/google/cloud/firestore/spi/v1/GrpcFirestoreRpc.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff 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);

0 commit comments

Comments
 (0)