|
@@ -453,7 +453,7 @@ class P2P:
|
|
|
) -> Awaitable[TOutputProtobuf]:
|
|
|
|
|
|
if not isinstance(input, AsyncIterableABC):
|
|
|
- return self._call_unary_protobuf_handler(peer_id, name, input, output_protobuf_type)
|
|
|
+ return await self._call_unary_protobuf_handler(peer_id, name, input, output_protobuf_type)
|
|
|
|
|
|
responses = self._iterate_protobuf_stream_handler(peer_id, name, input, output_protobuf_type)
|
|
|
|