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

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

Author: pre-commit-ci[bot]

python/psqlpy/_internal/__init__.pyi

@@ -1775,46 +1775,45 @@ class Listener:
         self: Self,
         channel: str,
         callback: Callable[
-            [str, str, int, Connection], Awaitable[None],
+            [str, str, int, Connection],
+            Awaitable[None],
         ],
     ) -> None:
         """Add callback to the channel.
-        
+
         Callback must be async function and have signature like this:
         ```python
         async def callback(
             channel: str,
             payload: str,
             process_id: str,
             connection: Connection,
-        ) -> None:
-            ...
+        ) -> None: ...
         ```
         """
-    
+
     async def clear_channel_callbacks(self, channel: str) -> None:
         """Remove all callbacks for the channel.
-        
+
         ### Parameters:
         - `channel`: name of the channel.
         """
 
     async def listen(self: Self) -> None:
         """Start listening.
 
-        Start actual listening.  
-        In the background it creates task in Rust event loop.  
+        Start actual listening.
+        In the background it creates task in Rust event loop.
         You must save returned Future to the array.
         """
 
     async def abort_listen(self: Self) -> None:
         """Abort listen.
-        
-        If `listen()` method was called, stop listening,  
+
+        If `listen()` method was called, stop listening,
         else don't do anything.
         """
 
-
 class ListenerNotificationMsg:
     """Listener message in async iterator."""
 

src/driver/listener/core.rs

@@ -115,7 +115,7 @@ impl Listener {
 
             return Ok(());
         }
-        
+
         return Err(RustPSQLDriverError::ListenerClosedError)
     }
 

src/driver/listener/structs.rs

@@ -74,17 +74,17 @@ impl ListenerNotificationMsg {
     fn process_id(&self) -> i32 {
         self.process_id
     }
-    
+
     #[getter]
     fn channel(&self) -> String {
         self.channel.clone()
     }
-    
+
     #[getter]
     fn payload(&self) -> String {
         self.payload.clone()
     }
-    
+
     #[getter]
     fn connection(&self) -> Connection {
         self.connection.clone()
@@ -129,7 +129,7 @@ impl ListenerCallback {
             }
             (self.callback.clone(), None)
         });
-        
+
         if let Some(task_locals) = task_locals {
             tokio_runtime().spawn(pyo3_async_runtimes::tokio::scope(task_locals, async move {
                 let future = Python::with_gil(|py| {