Skip to content

Commit 3cda13c

Browse files
committed
Typo fixes
1 parent 7e0648f commit 3cda13c

File tree

3 files changed

+13
-13
lines changed

3 files changed

+13
-13
lines changed

query/src/test/java/tech/ydb/query/impl/GrpcTestInterceptor.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,12 @@ public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
4444

4545
private static class ProxyClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
4646
private final ClientCall<ReqT, RespT> delegate;
47-
private final Status overrided;
47+
private final Status overriden;
4848

49-
private ProxyClientCall(Channel channel, Status overrided, MethodDescriptor<ReqT, RespT> method,
49+
private ProxyClientCall(Channel channel, Status overriden, MethodDescriptor<ReqT, RespT> method,
5050
CallOptions callOptions) {
5151
this.delegate = channel.newCall(method, callOptions);
52-
this.overrided = overrided;
52+
this.overriden = overriden;
5353
}
5454

5555
@Override
@@ -112,7 +112,7 @@ public void onMessage(RespT message) {
112112

113113
@Override
114114
public void onClose(Status status, Metadata trailers) {
115-
delegate.onClose(overrided != null ? overrided : status, trailers);
115+
delegate.onClose(overriden != null ? overriden : status, trailers);
116116
}
117117

118118
@Override

table/src/main/java/tech/ydb/table/impl/BaseSession.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1418,17 +1418,17 @@ private void onClose(Status streamStatus, Throwable streamError) {
14181418

14191419
@Override
14201420
public CompletableFuture<Status> start(Observer<T> observer) {
1421-
origin.start(msg -> {
1422-
StatusIds.StatusCode statusCode = readStatusCode(msg);
1423-
if (statusCode == StatusIds.StatusCode.SUCCESS) {
1421+
origin.start(message -> {
1422+
StatusIds.StatusCode code = readStatusCode(message);
1423+
if (code == StatusIds.StatusCode.SUCCESS) {
14241424
try {
1425-
observer.onNext(readValue(msg));
1425+
observer.onNext(readValue(message));
14261426
} catch (Throwable th) {
14271427
operationError.update(th);
14281428
origin.cancel();
14291429
}
14301430
} else {
1431-
operationStatus.update(Status.of(StatusCode.fromProto(statusCode), Issue.fromPb(readIssues(msg))));
1431+
operationStatus.update(Status.of(StatusCode.fromProto(code), Issue.fromPb(readIssues(message))));
14321432
origin.cancel();
14331433
}
14341434
}).whenComplete(this::onClose);

table/src/test/java/tech/ydb/table/integration/GrpcTestInterceptor.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,12 @@ public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
4444

4545
private static class ProxyClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
4646
private final ClientCall<ReqT, RespT> delegate;
47-
private final Status overrided;
47+
private final Status overriden;
4848

49-
private ProxyClientCall(Channel channel, Status overrided, MethodDescriptor<ReqT, RespT> method,
49+
private ProxyClientCall(Channel channel, Status overriden, MethodDescriptor<ReqT, RespT> method,
5050
CallOptions callOptions) {
5151
this.delegate = channel.newCall(method, callOptions);
52-
this.overrided = overrided;
52+
this.overriden = overriden;
5353
}
5454

5555
@Override
@@ -112,7 +112,7 @@ public void onMessage(RespT message) {
112112

113113
@Override
114114
public void onClose(Status status, Metadata trailers) {
115-
delegate.onClose(overrided != null ? overrided : status, trailers);
115+
delegate.onClose(overriden != null ? overriden : status, trailers);
116116
}
117117

118118
@Override

0 commit comments

Comments
 (0)