Skip to content

Commit e303363

Browse files
committed
change grpc api calls order
1 parent 54e2e7b commit e303363

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/main/java/tech/ydb/core/impl/call/ReadStreamCall.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,13 +59,13 @@ public CompletableFuture<Status> start(Observer<RespT> observer) {
5959
synchronized (call) {
6060
try {
6161
call.start(this, headers);
62-
call.request(1);
6362
if (logger.isTraceEnabled()) {
6463
logger.trace("ReadStreamCall[{}] --> {}", traceId, TextFormat.shortDebugString((Message) request));
6564
}
6665
call.sendMessage(request);
6766
// close stream by client side
6867
call.halfClose();
68+
call.request(1);
6969
} catch (Throwable t) {
7070
try {
7171
call.cancel(null, t);

core/src/main/java/tech/ydb/core/impl/call/UnaryCall.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,12 +50,12 @@ public UnaryCall(String traceId, ClientCall<ReqT, RespT> call, GrpcStatusHandler
5050
public CompletableFuture<Result<RespT>> startCall(ReqT request, Metadata headers) {
5151
try {
5252
call.start(this, headers);
53-
call.request(1);
5453
if (logger.isTraceEnabled()) {
5554
logger.trace("UnaryCall[{}] --> {}", traceId, TextFormat.shortDebugString((Message) request));
5655
}
5756
call.sendMessage(request);
5857
call.halfClose();
58+
call.request(1);
5959
} catch (Exception ex) {
6060
future.completeExceptionally(ex);
6161
try {

0 commit comments

Comments
 (0)