fix:fix pyre check 2 (#8)

Author: LoveEatCandy

megstore/indexed/jsonline.py

@@ -10,7 +10,7 @@
     INDEX_FILE_POSTFIX,
     BaseIndexedReader,
     BaseIndexedWriter,
-    IndexHandler,
+    IndexHandlerReader,
     OpenBinaryIO,
 )
 from megstore.interface import T
@@ -60,7 +60,7 @@ def _read_jsonline(self, file_object: BinaryIO, lineno: Optional[int] = None):
     def _build_index(
         cls,
         file_object: BinaryIO,
-        offsets: Union[IndexHandler, array],
+        offsets: Union[IndexHandlerReader, array],
         index_build_callback: Optional[Callable[[Any], None]] = None,
     ) -> int:
         """Build index from jsonline file object

megstore/indexed/msgpack.py

@@ -13,7 +13,6 @@
     INDEX_FILE_POSTFIX,
     BaseIndexedReader,
     Countable,
-    IndexHandler,
     IndexHandlerReader,
     IndexHandlerWriter,
 )
@@ -81,7 +80,7 @@ def _read_array_header(
     def _build_index(
         cls,
         fp_data: BinaryIO,
-        offsets: Union[IndexHandler, array],
+        offsets: Union[IndexHandlerReader, array],
         index_build_callback: Optional[Callable[[Any], None]] = None,
     ) -> int:
         """Build index from msgpack stream
@@ -109,7 +108,8 @@ def _build_index(
         except compat_msgpack.OutOfData:
             # Record length exceeds actual length, only return index of
             # actually read values, and the last tell() of unpacker
-            return current_offset
+            pass
+        return current_offset
 
     def _get(self, index: int) -> T:  # pytype: disable=invalid-annotation
         """Read a value by specified index
@@ -321,7 +321,7 @@ def _close(self):
             self._file_object.close()
 
 
-class IndexedMsgpackHandler(Appendable[T], IndexedMsgpackReader):
+class IndexedMsgpackHandler(IndexedMsgpackReader, Appendable[T]):
     def __init__(
         self,
         fp_msgpack: BinaryIO,

megstore/indexed/txt.py

@@ -8,7 +8,7 @@
     INDEX_FILE_POSTFIX,
     BaseIndexedReader,
     BaseIndexedWriter,
-    IndexHandler,
+    IndexHandlerReader,
 )
 from megstore.interface import OpenBinaryIO
 
@@ -52,7 +52,7 @@ def __init__(
     def _build_index(
         cls,
         file_object: BinaryIO,
-        offsets: Union[IndexHandler, array],
+        offsets: Union[IndexHandlerReader, array],
         index_build_callback: Optional[Callable[[Any], None]] = None,
     ) -> int:
         """Build index from txt stream