From 36d8d3bc851b06d94cf12a73048a00a67ef79c42 Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Mon, 4 Jul 2022 11:46:53 +0200 Subject: [PATCH] renaming --- pyinfra/server/stream/queued_stream_function.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/pyinfra/server/stream/queued_stream_function.py b/pyinfra/server/stream/queued_stream_function.py index 81563b6..dc93962 100644 --- a/pyinfra/server/stream/queued_stream_function.py +++ b/pyinfra/server/stream/queued_stream_function.py @@ -4,13 +4,18 @@ from pyinfra.server.buffering.queue import stream_queue, Queue class QueuedStreamFunction: - def __init__(self, fn): + def __init__(self, stream_function): + """Combines a stream function with a queue. + + Args: + stream_function: Needs to operate on iterables. + """ self.queue = Queue() - self.fn = fn + self.stream_function = stream_function def push(self, item): self.queue.append(item) def pop(self): items = stream_queue(self.queue) - return first(self.fn(items)) + return first(self.stream_function(items))