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

refactoring

Browse Source
This commit is contained in:
Matthias Bisping 2022-04-27 14:09:18 +02:00
parent 00e21b00ba
commit e58addf8c4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/fixtures/server.py vendored
View File

@ -7,7 +7,7 @@ from operator import itemgetter
import flask
import pytest
import requests
from funcy import retry, compose, repeatedly
from funcy import retry, compose, repeatedly, lmap
from waitress import serve
from test.server import set_up_processing_server
@ -53,7 +53,7 @@ def make_processor(operation, buffer_size=3):
items = repeatedly(buffer.pop, len(buffer)) if consume_buffer_now(buffer, data) else []
result = list(map(compose(bytes_to_string, operation), items))
result = lmap(compose(bytes_to_string, operation), items)
buffer.append(data)