Return all additional payload frames.

pyleco/core/internal_protocols.py

@@ -101,10 +101,10 @@ def ask(
     def interpret_rpc_response(
         self, response_message: Message, extract_additional_payload: bool = False
     ) -> Any:
-        """Retrieve the return value of a RPC response message or its binary payload."""
+        """Retrieve the return value of a RPC response message or the additional payload."""
         result = self.rpc_generator.get_result_from_response(response_message.payload[0])
         if extract_additional_payload and result is None and len(response_message.payload) > 1:
-            return response_message.payload[1]
+            return response_message.payload[1:]
         else:
             return result
 

tests/acceptance_tests/test_director_actor.py

@@ -148,4 +148,4 @@ def test_device_method_via_rpc(director: Director):
 def test_binary_data_transfer(director: Director):
     assert director.ask_rpc(
         method="binary_method", additional_payload=[b"123"], extract_additional_payload=True
-    ) == b"123123"
+    ) == [b"123123"]

tests/core/test_internal_protocols.py

@@ -88,11 +88,12 @@ def test_json_binary_response(self, communicator: FakeCommunicator):
         message = Message(
             receiver="rec",
             data={"jsonrpc": "2.0", "result": None, "id": 7},
-            additional_payload=[b"abcd"],
-        )
-        assert (
-            communicator.interpret_rpc_response(message, extract_additional_payload=True) == b"abcd"
+            additional_payload=[b"abcd", b"efgh"],
         )
+        assert communicator.interpret_rpc_response(message, extract_additional_payload=True) == [
+            b"abcd",
+            b"efgh",
+        ]
 
     def test_ignore_additional_payload_if_not_desired(self, communicator: FakeCommunicator):
         message = Message(