[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

buildutils/config.py

@@ -1,4 +1,5 @@
 """Config functions"""
+
 # -----------------------------------------------------------------------------
 #  Copyright (C) PyZMQ Developers
 #

buildutils/detect.py

@@ -1,4 +1,5 @@
 """Detect zmq version"""
+
 # -----------------------------------------------------------------------------
 #  Copyright (C) PyZMQ Developers
 #

examples/asyncio/coroutines.py

@@ -1,4 +1,5 @@
 """Example using zmq with asyncio coroutines"""
+
 # Copyright (c) PyZMQ Developers.
 # This example is in the public domain (CC-0)
 

examples/asyncio/router_router.py

@@ -12,6 +12,7 @@
 
 Contributed by github:jcpinto54 and github:frobnitzem
 """
+
 # Copyright (c) 2022 PyZMQ Developers.
 # This example is in the public domain (CC-0)
 

examples/asyncio/tornado_asyncio.py

@@ -1,4 +1,5 @@
 """Example showing ZMQ with asyncio and tornadoweb integration."""
+
 # Copyright (c) PyZMQ Developers.
 # This example is in the public domain (CC-0)
 

examples/device/device.py

@@ -1,4 +1,5 @@
 """Demonstrate using zmq.proxy device for message relay"""
+
 # This example is placed in the Public Domain
 # It may also be used under the Creative Commons CC-0 License, (C) PyZMQ Developers
 

examples/eventloop/asyncweb.py

@@ -8,7 +8,6 @@
 the event loop.
 """
 
-
 import asyncio
 import random
 import sys

examples/eventloop/coroutines.py

@@ -1,4 +1,5 @@
 """Example using zmq with tornado coroutines"""
+
 # Copyright (c) PyZMQ Developers.
 # This example is in the public domain (CC-0)
 

examples/gevent/reqrep.py

@@ -1,6 +1,7 @@
 """
 Complex example which is a combination of the rr* examples from the zguide.
 """
+
 from gevent import spawn
 
 import zmq.green as zmq

zmq/_future.py

@@ -275,14 +275,12 @@ def get(self, key):
     @overload  # type: ignore
     def recv_multipart(
         self, flags: int = 0, *, track: bool = False
-    ) -> Awaitable[List[bytes]]:
-        ...
+    ) -> Awaitable[List[bytes]]: ...
 
     @overload
     def recv_multipart(
         self, flags: int = 0, *, copy: Literal[True], track: bool = False
-    ) -> Awaitable[List[bytes]]:
-        ...
+    ) -> Awaitable[List[bytes]]: ...
 
     @overload
     def recv_multipart(
@@ -293,8 +291,7 @@ def recv_multipart(
     @overload
     def recv_multipart(
         self, flags: int = 0, copy: bool = True, track: bool = False
-    ) -> Awaitable[Union[List[bytes], List[_zmq.Frame]]]:
-        ...
+    ) -> Awaitable[Union[List[bytes], List[_zmq.Frame]]]: ...
 
     def recv_multipart(
         self, flags: int = 0, copy: bool = True, track: bool = False

zmq/eventloop/zmqstream.py

@@ -178,24 +178,21 @@ def on_err(self, callback: Callable):
     def on_recv(
         self,
         callback: Callable[[List[bytes]], Any],
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def on_recv(
         self,
         callback: Callable[[List[bytes]], Any],
         copy: Literal[True],
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def on_recv(
         self,
         callback: Callable[[List[zmq.Frame]], Any],
         copy: Literal[False],
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def on_recv(
@@ -205,8 +202,7 @@ def on_recv(
             Callable[[List[bytes]], Any],
         ],
         copy: bool = ...,
-    ):
-        ...
+    ): ...
 
     def on_recv(
         self,
@@ -254,24 +250,21 @@ def on_recv(
     def on_recv_stream(
         self,
         callback: Callable[["ZMQStream", List[bytes]], Any],
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def on_recv_stream(
         self,
         callback: Callable[["ZMQStream", List[bytes]], Any],
         copy: Literal[True],
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def on_recv_stream(
         self,
         callback: Callable[["ZMQStream", List[zmq.Frame]], Any],
         copy: Literal[False],
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def on_recv_stream(
@@ -281,8 +274,7 @@ def on_recv_stream(
             Callable[["ZMQStream", List[bytes]], Any],
         ],
         copy: bool = ...,
-    ):
-        ...
+    ): ...
 
     def on_recv_stream(
         self,

zmq/log/__main__.py

@@ -18,7 +18,6 @@
 
 """
 
-
 # encoding: utf-8
 
 # Copyright (C) PyZMQ Developers
@@ -113,12 +112,16 @@
 
             fields = {
                 'msg': msg.decode('utf8').strip(),
-                'ts': datetime.now().strftime(args.dateformat) + ' '
-                if args.timestamp
-                else '',
-                'aligned': '.'.join(aligned_parts)
-                if args.align
-                else topic.decode('utf8').strip(),
+                'ts': (
+                    datetime.now().strftime(args.dateformat) + ' '
+                    if args.timestamp
+                    else ''
+                ),
+                'aligned': (
+                    '.'.join(aligned_parts)
+                    if args.align
+                    else topic.decode('utf8').strip()
+                ),
                 'color': colors.get(level, ''),
                 'color_rst': colors.get('__RESET__', ''),
                 'sep': args.separator,

zmq/sugar/context.py

@@ -86,17 +86,15 @@ class Context(ContextBase, AttributeSetter, Generic[ST]):
     _socket_class: Type[ST] = Socket  # type: ignore
 
     @overload
-    def __init__(self: "Context[Socket]", io_threads: int = 1):
-        ...
+    def __init__(self: "Context[Socket]", io_threads: int = 1): ...
 
     @overload
     def __init__(self: "Context[Socket]", io_threads: "Context"):
         # this should be positional-only, but that requires 3.8
         ...
 
     @overload
-    def __init__(self: "Context[Socket]", *, shadow: Union["Context", int]):
-        ...
+    def __init__(self: "Context[Socket]", *, shadow: Union["Context", int]): ...
 
     def __init__(
         self: "Context[Socket]",

zmq/sugar/socket.py

@@ -109,24 +109,21 @@ def __init__(
         socket_type: int,
         *,
         copy_threshold: Optional[int] = None,
-    ):
-        ...
+    ): ...
 
     @overload
     def __init__(
         self: "Socket[bytes]",
         *,
         shadow: Union["Socket", int],
         copy_threshold: Optional[int] = None,
-    ):
-        ...
+    ): ...
 
     @overload
     def __init__(
         self: "Socket[bytes]",
         ctx_or_socket: "Socket",
-    ):
-        ...
+    ): ...
 
     def __init__(
         self: "Socket[bytes]",
@@ -578,8 +575,7 @@ def send(
         track: Literal[True],
         routing_id: Optional[int] = ...,
         group: Optional[str] = ...,
-    ) -> "zmq.MessageTracker":
-        ...
+    ) -> "zmq.MessageTracker": ...
 
     @overload
     def send(
@@ -591,8 +587,7 @@ def send(
         track: Literal[False],
         routing_id: Optional[int] = ...,
         group: Optional[str] = ...,
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def send(
@@ -603,8 +598,7 @@ def send(
         copy: bool = ...,
         routing_id: Optional[int] = ...,
         group: Optional[str] = ...,
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @overload
     def send(
@@ -615,8 +609,7 @@ def send(
         track: bool = ...,
         routing_id: Optional[int] = ...,
         group: Optional[str] = ...,
-    ) -> Optional["zmq.MessageTracker"]:
-        ...
+    ) -> Optional["zmq.MessageTracker"]: ...
 
     def send(
         self,
@@ -755,24 +748,20 @@ def send_multipart(
     @overload
     def recv_multipart(
         self, flags: int = ..., *, copy: Literal[True], track: bool = ...
-    ) -> List[bytes]:
-        ...
+    ) -> List[bytes]: ...
 
     @overload
     def recv_multipart(
         self, flags: int = ..., *, copy: Literal[False], track: bool = ...
-    ) -> List[zmq.Frame]:
-        ...
+    ) -> List[zmq.Frame]: ...
 
     @overload
-    def recv_multipart(self, flags: int = ..., *, track: bool = ...) -> List[bytes]:
-        ...
+    def recv_multipart(self, flags: int = ..., *, track: bool = ...) -> List[bytes]: ...
 
     @overload
     def recv_multipart(
         self, flags: int = 0, copy: bool = True, track: bool = False
-    ) -> Union[List[zmq.Frame], List[bytes]]:
-        ...
+    ) -> Union[List[zmq.Frame], List[bytes]]: ...
 
     def recv_multipart(
         self, flags: int = 0, copy: bool = True, track: bool = False

zmq/tests/test_asyncio.py

@@ -1,4 +1,5 @@
 """Test asyncio support"""
+
 # Copyright (c) PyZMQ Developers
 # Distributed under the terms of the Modified BSD License.
 

zmq/tests/test_imports.py

@@ -2,6 +2,7 @@
 Test Imports - the quickest test to ensure that we haven't
 introduced version-incompatible syntax errors.
 """
+
 # Copyright (C) PyZMQ Developers
 # Distributed under the terms of the Modified BSD License.
 

zmq/tests/test_mypy.py

@@ -1,6 +1,7 @@
 """
 Test our typing with mypy
 """
+
 import os
 import sys
 from subprocess import PIPE, STDOUT, Popen

zmq/utils/monitor.py

@@ -67,16 +67,14 @@ async def _parse_monitor_msg_async(
 def recv_monitor_message(
     socket: "zmq.asyncio.Socket",
     flags: int = 0,
-) -> Awaitable[_MonitorMessage]:
-    ...
+) -> Awaitable[_MonitorMessage]: ...
 
 
 @overload
 def recv_monitor_message(
     socket: zmq.Socket[bytes],
     flags: int = 0,
-) -> _MonitorMessage:
-    ...
+) -> _MonitorMessage: ...
 
 
 def recv_monitor_message(

zmq/utils/win32.py

@@ -81,9 +81,9 @@ def _init_action(self, action):
 
         # <http://msdn.microsoft.com/en-us/library/ms686016.aspx>
         PHANDLER_ROUTINE = WINFUNCTYPE(BOOL, DWORD)
-        SetConsoleCtrlHandler = (
-            self._SetConsoleCtrlHandler
-        ) = kernel32.SetConsoleCtrlHandler
+        SetConsoleCtrlHandler = self._SetConsoleCtrlHandler = (
+            kernel32.SetConsoleCtrlHandler
+        )
         SetConsoleCtrlHandler.argtypes = (PHANDLER_ROUTINE, BOOL)
         SetConsoleCtrlHandler.restype = BOOL