Skip to content

Commit 9cc264e

Browse files
committed
Fix bug when calling nats_conn.request
1 parent 1663c3d commit 9cc264e

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/nats_multi_request/__init__.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -26,20 +26,17 @@ async def add_to_list(msg: Msg):
2626
if len(responses) == expected:
2727
sleep_timeout.cancel()
2828

29-
sid = await nats_conn.request(
29+
await nats_conn.request(
3030
subject,
3131
payload,
3232
timeout=timeout,
33-
expected=expected,
3433
cb=add_to_list,
3534
)
3635

3736
try:
3837
await sleep_timeout
3938
except asyncio.CancelledError:
4039
pass
41-
42-
await nats_conn.unsubscribe(sid)
4340
return responses
4441

4542

0 commit comments

Comments
 (0)