From b12ac5074712682b3f916ca1aec85bd98f52e462 Mon Sep 17 00:00:00 2001 From: Artem30801 Date: Tue, 29 Oct 2019 17:38:31 +0300 Subject: [PATCH] Resending improval (for furthrer functionality & fixes --- messaging_lib.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/messaging_lib.py b/messaging_lib.py index 8f1b8b8..f9e7bcf 100644 --- a/messaging_lib.py +++ b/messaging_lib.py @@ -19,7 +19,7 @@ except ImportError: PendingRequest = collections.namedtuple("PendingRequest", ["value", "requested_value", # "expires_on", "callback", "callback_args", "callback_kwargs", - "resend" + "request_args", "resend", ]) logger = logging.getLogger(__name__) @@ -442,6 +442,7 @@ class ConnectionManager(object): callback=callback, callback_args=callback_args, callback_kwargs=callback_kwargs, + request_args=request_args, resend=True, ) self._send(MessageManager.create_request(requested_value, request_id, request_args)) @@ -451,7 +452,7 @@ class ConnectionManager(object): for request_id, request in self._request_queue.items(): if request.resend: self._send(MessageManager.create_request( - request.requested_value, request_id, request.request_args) + request.requested_value, request_id, request.request_args.update(resend=request.resend)) ) request.resend = False