@@ -137,36 +137,6 @@ def get_range(
137137 writer .seek (0 ) # rewind for read
138138 return DBNStore .from_bytes (writer .read ())
139139
140- @deprecated
141- async def stream_async (
142- self ,
143- dataset : Union [Dataset , str ],
144- start : Union [pd .Timestamp , date , str , int ],
145- end : Optional [Union [pd .Timestamp , date , str , int ]] = None ,
146- symbols : Optional [Union [List [str ], str ]] = None ,
147- schema : Union [Schema , str ] = "trades" ,
148- stype_in : Union [SType , str ] = "raw_symbol" ,
149- stype_out : Union [SType , str ] = "instrument_id" ,
150- limit : Optional [int ] = None ,
151- path : Optional [Union [PathLike [str ], str ]] = None ,
152- ) -> DBNStore :
153- """
154- The `.stream_async` method is deprecated and will be removed in a future
155- version.
156- The method has been renamed to `.get_range_async`, which you can now use.
157- """
158- return await self .get_range_async (
159- dataset = dataset ,
160- start = start ,
161- end = end ,
162- symbols = symbols ,
163- schema = schema ,
164- stype_in = stype_in ,
165- stype_out = stype_out ,
166- limit = limit ,
167- path = path ,
168- )
169-
170140 async def get_range_async (
171141 self ,
172142 dataset : Union [Dataset , str ],
0 commit comments