Skip to content

Commit eb4c904

Browse files
committed
Fixed readed -> read
1 parent 44e709c commit eb4c904

File tree

6 files changed

+6
-6
lines changed

6 files changed

+6
-6
lines changed

core/src/main/java/tech/ydb/core/grpc/GrpcFlowControl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
public interface GrpcFlowControl {
1111
interface Call {
1212
void onStart();
13-
void onMessageReaded();
13+
void onMessageRead();
1414
}
1515

1616
Call newCall(IntConsumer req);

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public void onStart() {
2626
}
2727

2828
@Override
29-
public void onMessageReaded() {
29+
public void onMessageRead() {
3030
req.accept(1);
3131
}
3232
}

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
@@ -114,7 +114,7 @@ public void onMessage(RespT message) {
114114
logger.trace("ReadStreamCall[{}] <-- {}", traceId, TextFormat.shortDebugString((Message) message));
115115
}
116116
consumer.onNext(message);
117-
flow.onMessageReaded();
117+
flow.onMessageRead();
118118
} catch (Exception ex) {
119119
statusFuture.completeExceptionally(ex);
120120

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ public void onMessage(R message) {
153153
}
154154

155155
consumer.onNext(message);
156-
flow.onMessageReaded();
156+
flow.onMessageRead();
157157
} catch (Exception ex) {
158158
statusFuture.completeExceptionally(ex);
159159
try {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ public void onStart() {
174174
}
175175

176176
@Override
177-
public void onMessageReaded() {
177+
public void onMessageRead() {
178178
semaphore.release();
179179
}
180180
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,7 @@ public void onStart() {
225225
}
226226

227227
@Override
228-
public void onMessageReaded() {
228+
public void onMessageRead() {
229229
semaphore.release();
230230
}
231231
}

0 commit comments

Comments
 (0)