MOD: Switch to write_and_decode()

Author: nmacholl

databento/common/dbnstore.py

@@ -391,8 +391,7 @@ def __iter__(self) -> Generator[DBNRecord, None, None]:
         while True:
             raw = reader.read(DBNStore.DBN_READ_SIZE)
             if raw:
-                decoder.write(raw)
-                records = decoder.decode()
+                records = decoder.write_and_decode(raw)
                 for record in records:
                     if isinstance(record, databento_dbn.Metadata):
                         continue

databento/live/protocol.py

@@ -375,8 +375,7 @@ def _process_dbn(self, data: bytes) -> None:
             raise ValueError("not connected")
 
         try:
-            self._dbn_decoder.write(data)
-            records = self._dbn_decoder.decode()
+            records = self._dbn_decoder.write_and_decode(data)
         except Exception:
             logger.exception("error decoding DBN record")
             self.__transport.close()