From 024aceda53fe6d1ab8d519b73584437c25de6975 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Wed, 14 Sep 2022 12:25:25 -0400 Subject: [PATCH] feedback --- hub/herald/session.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hub/herald/session.py b/hub/herald/session.py index 501a68b..40b5085 100644 --- a/hub/herald/session.py +++ b/hub/herald/session.py @@ -1109,7 +1109,7 @@ class LBRYElectrumX(asyncio.Protocol): def send_notification(self, method, args=()): self._task_group.add(self._send_notification(method, args)) - async def send_notifications(self, notifications) -> bool: + async def _send_notifications(self, notifications) -> bool: """Send an RPC notification over the network.""" message, _ = self.connection.send_batch(notifications) try: @@ -1215,7 +1215,7 @@ class LBRYElectrumX(asyncio.Protocol): self.NOTIFICATION_COUNT.labels(method='blockchain.address.subscribe', ).inc(address_notifications) self.session_manager.notifications_in_flight_metric.inc(len(notifications)) try: - await self.send_notifications(Batch(notifications)) + await self._send_notifications(Batch(notifications)) self.session_manager.notifications_sent_metric.observe(time.perf_counter() - start) finally: self.session_manager.notifications_in_flight_metric.dec(len(notifications))