diff --git a/test/fixtures/server.py b/test/fixtures/server.py
index 8bcae9d..341c575 100644
--- a/test/fixtures/server.py
+++ b/test/fixtures/server.py
@@ -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)