Merge pull request #100 from truh/cleanup-unused-loops

Cleanup unused loops

.gitignore

@@ -13,3 +13,4 @@ __pycache__/
 venv/
 Pipfile.lock
 .envrc
+.pdm-python

README.md

@@ -115,13 +115,13 @@ that does not rely on async generators but instead uses memory channels (`exampl
 
 ## Development, Contributing
 1. install pdm: `pip install pdm`
-2. install dependencies using pipenv: `pdm install -d.`
+2. install dependencies using pipenv: `pdm install -d`.
 3. To run tests:
 
 ### Makefile
 - make sure your virtualenv is active
 - check `Makefile` for available commands and development support, e.g. run the unit tests:
-```python
+```shell
 make test
 make tox
 ```

tests/integration/test_multiple_consumers.py

@@ -155,10 +155,9 @@ def test_stop_server_with_many_consumers(caplog, server_command, expected_lines)
     if server_process is None or server_process.poll() is not None:
         pytest.fail("Server did not start.")
 
-    # Initialize asyncio loops and threads
-    loops = [asyncio.new_event_loop() for _ in range(N_CONSUMER)]
+    # Initialize threads
     threads = []
-    for loop in loops:
+    for _ in range(N_CONSUMER):
         thread = threading.Thread(
             target=lambda: asyncio.run(
                 make_arequest(f"{URL}:{port}/endless", expected_lines=expected_lines)