1
1
class SequentialCompressionReader :
2
2
def __init__ (self ) -> None : ...
3
+ def close (self ) -> None : ...
3
4
def get_all_message_definitions (self , * args , ** kwargs ): ...
4
5
def get_all_topics_and_types (self , * args , ** kwargs ): ...
5
6
def get_metadata (self , * args , ** kwargs ): ...
6
7
def has_next (self ) -> bool : ...
7
8
def open (self , arg0 , arg1 ) -> None : ...
8
- def close (self ) -> None : ...
9
9
def open_uri (self , arg0 : str ) -> None : ...
10
10
def read_next (self ) -> tuple : ...
11
11
def reset_filter (self ) -> None : ...
@@ -15,12 +15,12 @@ class SequentialCompressionReader:
15
15
16
16
class SequentialReader :
17
17
def __init__ (self ) -> None : ...
18
+ def close (self ) -> None : ...
18
19
def get_all_message_definitions (self , * args , ** kwargs ): ...
19
20
def get_all_topics_and_types (self , * args , ** kwargs ): ...
20
21
def get_metadata (self , * args , ** kwargs ): ...
21
22
def has_next (self ) -> bool : ...
22
23
def open (self , arg0 , arg1 ) -> None : ...
23
- def close (self ) -> None : ...
24
24
def open_uri (self , arg0 : str ) -> None : ...
25
25
def read_next (self ) -> tuple : ...
26
26
def reset_filter (self ) -> None : ...
0 commit comments