|
|
|
@ -135,7 +135,6 @@ class NotificationSession(RPCSession): |
|
|
|
super(NotificationSession, self).__init__(*args, **kwargs) |
|
|
|
super(NotificationSession, self).__init__(*args, **kwargs) |
|
|
|
self.subscriptions = defaultdict(list) |
|
|
|
self.subscriptions = defaultdict(list) |
|
|
|
self.cache = {} |
|
|
|
self.cache = {} |
|
|
|
self.default_timeout = NetworkTimeout.Generic.NORMAL |
|
|
|
|
|
|
|
self._msg_counter = itertools.count(start=1) |
|
|
|
self._msg_counter = itertools.count(start=1) |
|
|
|
self.interface = interface |
|
|
|
self.interface = interface |
|
|
|
self.cost_hard_limit = 0 # disable aiorpcx resource limits |
|
|
|
self.cost_hard_limit = 0 # disable aiorpcx resource limits |
|
|
|
@ -183,7 +182,9 @@ class NotificationSession(RPCSession): |
|
|
|
return response |
|
|
|
return response |
|
|
|
|
|
|
|
|
|
|
|
def set_default_timeout(self, timeout): |
|
|
|
def set_default_timeout(self, timeout): |
|
|
|
|
|
|
|
assert hasattr(self, "sent_request_timeout") # in base class |
|
|
|
self.sent_request_timeout = timeout |
|
|
|
self.sent_request_timeout = timeout |
|
|
|
|
|
|
|
assert hasattr(self, "max_send_delay") # in base class |
|
|
|
self.max_send_delay = timeout |
|
|
|
self.max_send_delay = timeout |
|
|
|
|
|
|
|
|
|
|
|
async def subscribe(self, method: str, params: List, queue: asyncio.Queue): |
|
|
|
async def subscribe(self, method: str, params: List, queue: asyncio.Queue): |
|
|
|
|