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

refactoring: rename

Browse Source
This commit is contained in:
Matthias Bisping 2022-05-05 14:25:24 +02:00
parent 4fd6a5aa2a
commit 7ccad043f4
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pyinfra/server/interpreter/interpreters/rest_callback.py
View File

@ -18,6 +18,6 @@ def stream_response_payloads(endpoint):
yield from response_stream
class PickupStreamer(Interpreter):
class RestPickupStreamer(Interpreter):
def __call__(self, payloads: Iterable):
yield from mapcat(stream_response_payloads, payloads)

4
pyinfra/server/rest.py
View File

@ -5,7 +5,7 @@ from funcy import rcompose
from pyinfra.server.dispatcher.senders.rest import RestDispatcher
from pyinfra.server.interpreter.interpreters.identity import IdentityInterpreter
from pyinfra.server.interpreter.interpreters.rest_callback import PickupStreamer
from pyinfra.server.interpreter.interpreters.rest_callback import RestPickupStreamer
from pyinfra.server.packer.packers.rest import RestPacker
from pyinfra.server.pipeline import Pipeline
from pyinfra.server.receiver.receivers.rest import RestReceiver
@ -30,7 +30,7 @@ def process_lazily(url, data: Iterable[bytes], metadata: Iterable[dict]):
- responses must have status code 206 for more responses coming and 204 for the last response already sent
"""
pipeline = Pipeline(*pipeline_head(url), rcompose(PickupStreamer(), RestReceiver()))
pipeline = Pipeline(*pipeline_head(url), rcompose(RestPickupStreamer(), RestReceiver()))
yield from pipeline(data, metadata)