fix getNormalOffset in SubscriptionOffset (#34)

daleiz · web-flow · commit aed83d5a55c0 · 2021-10-11T17:16:41.000+08:00
diff --git a/client/src/main/java/io/hstream/SubscriptionOffset.java b/client/src/main/java/io/hstream/SubscriptionOffset.java
@@ -43,7 +43,7 @@ public SpecialOffset getSpecialOffset() {
   }
 
   public RecordId getNormalOffset() {
-    if (isSpecialOffset()) {
+    if (isNormalOffset()) {
       return recordId;
     } else {
       throw new IllegalStateException("subscriptionOffset is not normal offset");

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ public SpecialOffset getSpecialOffset() {`
`43`	`43`	`}`
`44`	`44`
`45`	`45`	`public RecordId getNormalOffset() {`
`46`		`- if (isSpecialOffset()) {`
	`46`	`+ if (isNormalOffset()) {`
`47`	`47`	`return recordId;`
`48`	`48`	`} else {`
`49`	`49`	`throw new IllegalStateException("subscriptionOffset is not normal offset");`