Fix to spec

Teslemetry · Mar 17, 2024 · bf663da · bf663da
1 parent a50f4e3
commit bf663da
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/teslemetry_stream/__init__.py b/teslemetry_stream/__init__.py
@@ -146,8 +146,9 @@ async def __anext__(self) -> dict:
                 # Connect to the stream
                 await self.connect()
             async for line_in_bytes in self._response.content:
-                if raw := line_in_bytes.decode("utf8").partition(": ")[2]:
-                    data = json.loads(raw)
+                field, _, value = line_in_bytes.decode("utf8").partition(": ")
+                if field == "data":
+                    data = json.loads(value)
                     if self.parse_timestamp:
                         main, _, ns = data["createdAt"].partition(".")
                         data["timestamp"] = int(