From 4e85f3435348125e792582db442bd1551e63c3a0 Mon Sep 17 00:00:00 2001 From: Lex Berezhny Date: Sun, 12 Apr 2020 12:05:03 -0400 Subject: [PATCH] pylint --- lbry/wallet/stream.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lbry/wallet/stream.py b/lbry/wallet/stream.py index 4b19b66d3..2c80bcd00 100644 --- a/lbry/wallet/stream.py +++ b/lbry/wallet/stream.py @@ -66,7 +66,7 @@ class StreamController: next_sub = next_sub._next yield subscription - def _notify_and_create_task(self, notify): + def _notify_and_ensure_future(self, notify): tasks = [] for subscription in self._iterate_subscriptions: maybe_coroutine = notify(subscription) @@ -82,7 +82,7 @@ class StreamController: def add(self, event): skip = self._merge_repeated and event == self._last_event self._last_event = event - return self._notify_and_create_task( + return self._notify_and_ensure_future( lambda subscription: None if skip else subscription._add(event) )