Skip to content

Commit afb0eb9

Browse files
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
1 parent b797616 commit afb0eb9

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

tests/test_asyncio.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,12 @@
1111
from multiprocessing import Process
1212

1313
import pytest
14+
from anyio import create_task_group, move_on_after, sleep
15+
from anyioutils import CancelledError, create_task
1416
from pytest import mark
1517

1618
import zmq
1719
import zmq.asyncio as zaio
18-
from anyio import create_task_group, move_on_after, sleep
19-
from anyioutils import CancelledError, create_task
2020

2121
pytestmark = pytest.mark.anyio
2222

zmq/_future.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -105,9 +105,13 @@ def _clear_wrapper_io(f):
105105
socket = self._socket_class.from_socket(socket)
106106
wrapped_sockets.append(socket)
107107
if mask & _zmq.POLLIN:
108-
create_task(socket._add_recv_event(tg, 'poll', future=watcher), tg)
108+
create_task(
109+
socket._add_recv_event(tg, 'poll', future=watcher), tg
110+
)
109111
if mask & _zmq.POLLOUT:
110-
create_task(socket._add_send_event(tg, 'poll', future=watcher), tg)
112+
create_task(
113+
socket._add_send_event(tg, 'poll', future=watcher), tg
114+
)
111115
else:
112116
raw_sockets.append(socket)
113117
evt = 0

0 commit comments

Comments
 (0)