Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Oct 30, 2024
1 parent b797616 commit afb0eb9
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 4 deletions.
4 changes: 2 additions & 2 deletions tests/test_asyncio.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,12 @@
from multiprocessing import Process

import pytest
from anyio import create_task_group, move_on_after, sleep
from anyioutils import CancelledError, create_task
from pytest import mark

import zmq
import zmq.asyncio as zaio
from anyio import create_task_group, move_on_after, sleep
from anyioutils import CancelledError, create_task

pytestmark = pytest.mark.anyio

Expand Down
8 changes: 6 additions & 2 deletions zmq/_future.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,9 +105,13 @@ def _clear_wrapper_io(f):
socket = self._socket_class.from_socket(socket)
wrapped_sockets.append(socket)
if mask & _zmq.POLLIN:
create_task(socket._add_recv_event(tg, 'poll', future=watcher), tg)
create_task(
socket._add_recv_event(tg, 'poll', future=watcher), tg
)
if mask & _zmq.POLLOUT:
create_task(socket._add_send_event(tg, 'poll', future=watcher), tg)
create_task(
socket._add_send_event(tg, 'poll', future=watcher), tg
)
else:
raw_sockets.append(socket)
evt = 0
Expand Down

0 comments on commit afb0eb9

Please sign in to comment.