created concurrency limit configurable

2025-12-31 20:36:24 +00:00 · 2025-07-03 11:53:58 +05:30
parent 383d7cb722
commit 8bfd4bde94
1 changed files with 1 additions and 0 deletions
--- a/libp2p/identity/identify_push/identify_push.py
+++ b/libp2p/identity/identify_push/identify_push.py
@ -178,6 +178,7 @@ async def push_identify_to_peers(
    observed_multiaddr: Multiaddr | None = None,
    counter: dict[str, int] | None = None,
    lock: trio.Lock | None = None,
+    limit: int = CONCURRENCY_LIMIT,
 ) -> int:  # <-- return the max concurrency
    """
    Push an identify message to multiple peers in parallel.