Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

renaming

Browse Source
This commit is contained in:
Matthias Bisping 2022-05-17 12:12:43 +02:00
parent fb325ce43d
commit 47f1d77c03
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pyinfra/server/dispatcher/dispatchers/queue.py
View File

@ -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)