Skip to content

Commit 672b992

Browse files
authored
fix typo (#133)
1 parent 77edf66 commit 672b992

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

client/src/main/java/io/hstream/Subscription.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public class Subscription {
1515
private SubscriptionOffset offset;
1616

1717
public enum SubscriptionOffset {
18-
EARLEST,
18+
EARLIEST,
1919
LATEST,
2020
}
2121

client/src/main/java/io/hstream/util/GrpcUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public static RecordId recordIdToGrpc(String recordId) {
2929

3030
public static SpecialOffset subscriptionOffsetToGrpc(Subscription.SubscriptionOffset offset) {
3131
switch (offset) {
32-
case EARLEST:
32+
case EARLIEST:
3333
return io.hstream.internal.SpecialOffset.EARLIEST;
3434
case LATEST:
3535
return io.hstream.internal.SpecialOffset.LATEST;
@@ -41,7 +41,7 @@ public static SpecialOffset subscriptionOffsetToGrpc(Subscription.SubscriptionOf
4141
public static Subscription.SubscriptionOffset subscriptionOffsetFromGrpc(SpecialOffset offset) {
4242
switch (offset) {
4343
case EARLIEST:
44-
return Subscription.SubscriptionOffset.EARLEST;
44+
return Subscription.SubscriptionOffset.EARLIEST;
4545
case LATEST:
4646
return Subscription.SubscriptionOffset.LATEST;
4747
default:

0 commit comments

Comments
 (0)