unnecessary utf decode pre-loads

src/pylutron_caseta/leap.py

@@ -85,7 +85,7 @@ async def run(self):
             if received == b"":
                 break
 
-            resp_json = orjson.loads(received.decode("UTF-8"))
+            resp_json = orjson.loads(received)
 
             if isinstance(resp_json, dict):
                 tag = resp_json.get("Header", {}).pop("ClientTag", None)

src/pylutron_caseta/pairing.py

@@ -57,7 +57,7 @@ async def async_read_json(self, timeout):
             return None
 
         LOGGER.debug("received: %s", buffer)
-        return orjson.loads(buffer.decode("UTF-8"))
+        return orjson.loads(buffer)
 
     async def async_write_json(self, obj):
         """Write an object."""

tests/test_leap.py

@@ -109,7 +109,7 @@ async def test_call(pipe: Pipe):
     """Test basic call and response."""
     task = asyncio.create_task(pipe.leap.request("ReadRequest", "/test"))
 
-    received = orjson.loads((await pipe.test_reader.readline()).decode("utf-8"))
+    received = orjson.loads(await pipe.test_reader.readline())
 
     # message should contain ClientTag
     tag = received.get("Header", {}).pop("ClientTag", None)
@@ -232,7 +232,7 @@ def handler(response):
 
     task = asyncio.create_task(pipe.leap.subscribe("/test", handler))
 
-    received = orjson.loads((await pipe.test_reader.readline()).decode("utf-8"))
+    received = orjson.loads(await pipe.test_reader.readline())
 
     # message should contain ClientTag
     tag = received.get("Header", {}).pop("ClientTag", None)
@@ -287,7 +287,7 @@ def _handler(_: Response):
 
     task = asyncio.create_task(pipe.leap.subscribe("/test", _handler))
 
-    received = orjson.loads((await pipe.test_reader.readline()).decode("utf-8"))
+    received = orjson.loads(await pipe.test_reader.readline())
 
     tag = received.get("Header", {}).pop("ClientTag", None)
     response_obj = {