From dfcab7dcbf28769432565a3ca28d4b3324b43314 Mon Sep 17 00:00:00 2001 From: Kenneth Reitz Date: Mon, 15 Oct 2018 06:41:47 -0400 Subject: [PATCH] fix #47 --- responder/background.py | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/responder/background.py b/responder/background.py index 8ef168e..e808e5c 100644 --- a/responder/background.py +++ b/responder/background.py @@ -10,7 +10,6 @@ class BackgroundQueue: self.n = n self.pool = concurrent.futures.ThreadPoolExecutor(max_workers=n) self.results = [] - self.callbacks = [] def run(self, f, *args, **kwargs): self.pool._max_workers = self.n @@ -18,6 +17,7 @@ class BackgroundQueue: f = self.pool.submit(f, *args, **kwargs) self.results.append(f) + return f def task(self, f): def do_task(*args, **kwargs): @@ -29,11 +29,3 @@ class BackgroundQueue: return result return do_task - - def callback(self, f): - self.callbacks.append(f) - - def register_callback(): - f() - - return register_callback