From 47f1d77c034b3e83a9aa8db03be0682b49a803ac Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Tue, 17 May 2022 12:12:43 +0200 Subject: [PATCH] renaming --- pyinfra/server/dispatcher/dispatchers/queue.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pyinfra/server/dispatcher/dispatchers/queue.py b/pyinfra/server/dispatcher/dispatchers/queue.py index 390cc52..b61374b 100644 --- a/pyinfra/server/dispatcher/dispatchers/queue.py +++ b/pyinfra/server/dispatcher/dispatchers/queue.py @@ -1,13 +1,14 @@ from pyinfra.server.dispatcher.dispatcher import Dispatcher +from pyinfra.server.stream.queued_stream_function import QueuedStreamFunction class QueuedStreamFunctionDispatcher(Dispatcher): - def __init__(self, queue): - self.queue = queue + def __init__(self, queued_stream_function: QueuedStreamFunction): + self.queued_stream_function = queued_stream_function def patch(self, package): - self.queue.push(package) - return self.queue.pop() + self.queued_stream_function.push(package) + return self.queued_stream_function.pop() def post(self, package): return self.patch(package)