Denis Mazur преди 4 години
родител
ревизия
0358a75d21
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      hivemind/p2p/p2p_daemon.py

+ 1 - 1
hivemind/p2p/p2p_daemon.py

@@ -460,7 +460,7 @@ class P2P:
             return await self._call_unary_protobuf_handler(peer_id, name, input, output_protobuf_type)
 
         requests = input if isinstance(input, AsyncIterableABC) else aiter(input)
-        responses = self._iterate_protobuf_stream_handler(peer_id, name, input, output_protobuf_type)
+        responses = self._iterate_protobuf_stream_handler(peer_id, name, requests, output_protobuf_type)
 
         count = 0
         async for response in responses: