reformat

Author: egorsmkv

demo/picows_server.py

@@ -1,7 +1,14 @@
 import asyncio
 import rsloop
 
-from picows import ws_create_server, WSFrame, WSTransport, WSListener, WSMsgType, WSUpgradeRequest
+from picows import (
+    ws_create_server,
+    WSFrame,
+    WSTransport,
+    WSListener,
+    WSMsgType,
+    WSUpgradeRequest,
+)
 
 
 class ServerClientListener(WSListener):
@@ -28,6 +35,5 @@ def listener_factory(r: WSUpgradeRequest):
     await server.serve_forever()
 
 
-
 if __name__ == "__main__":
     rsloop.run(main())

src/loop_core.rs

@@ -448,11 +448,9 @@ impl LoopCore {
                     }
                     ReadyItem::ServerAccepted { server, stream } => {
                         profiling::scope!("ready.server_accepted");
-                        if let Err(err) =
-                            crate::stream_transport::spawn_accepted_transport_with_py(
-                                py, &server, stream,
-                            )
-                        {
+                        if let Err(err) = crate::stream_transport::spawn_accepted_transport_with_py(
+                            py, &server, stream,
+                        ) {
                             server.report_error(err, "failed to accept connection");
                         }
                     }
@@ -740,9 +738,12 @@ impl LoopCore {
                     ReadyItem::ProcessTransport(core) => {
                         LoopCommand::Transport(LoopTransportCommand::Process(core))
                     }
-                    ReadyItem::ServerAccepted { server, stream } => LoopCommand::Transport(
-                        LoopTransportCommand::ServerAccepted { server, stream },
-                    ),
+                    ReadyItem::ServerAccepted { server, stream } => {
+                        LoopCommand::Transport(LoopTransportCommand::ServerAccepted {
+                            server,
+                            stream,
+                        })
+                    }
                 }),
             LoopCommand::Future(LoopFutureCommand::SetResult { future, value }) => self
                 .try_enqueue_local_ready(ReadyItem::FutureSetResult { future, value })

src/loop_core/commands.rs

@@ -14,8 +14,14 @@ use crate::stream_transport::{
 
 pub enum ReadyItem {
     Callback(Arc<ReadyCallback>),
-    FutureSetResult { future: Py<PyAny>, value: Py<PyAny> },
-    FutureSetException { future: Py<PyAny>, value: Py<PyAny> },
+    FutureSetResult {
+        future: Py<PyAny>,
+        value: Py<PyAny>,
+    },
+    FutureSetException {
+        future: Py<PyAny>,
+        value: Py<PyAny>,
+    },
     StreamTransportRead(Arc<StreamTransportCore>),
     ProcessTransport(Arc<ProcessTransportCore>),
     ServerAccepted {

src/python_api.rs

@@ -1998,28 +1998,14 @@ impl PyLoop {
             )?;
             transport_from_socket_tls(
                 py,
-                stream_spawn_context(
-                    py,
-                    &core,
-                    &loop_obj,
-                    &protocol,
-                    &context,
-                    context_needs_run,
-                ),
+                stream_spawn_context(py, &core, &loop_obj, &protocol, &context, context_needs_run),
                 socket_obj,
                 tls,
             )
         } else {
             transport_from_socket(
                 py,
-                stream_spawn_context(
-                    py,
-                    &core,
-                    &loop_obj,
-                    &protocol,
-                    &context,
-                    context_needs_run,
-                ),
+                stream_spawn_context(py, &core, &loop_obj, &protocol, &context, context_needs_run),
                 socket_obj,
             )
         }?;

src/stream_transport.rs

@@ -3146,8 +3146,7 @@ pub(crate) fn spawn_accepted_transport_with_py(
 
 fn schedule_accepted_transport(server: &Arc<ServerCore>, stream: AcceptedStream, message: &str) {
     if server.tls.is_some() {
-        let result =
-            Python::try_attach(|py| spawn_accepted_transport_with_py(py, server, stream));
+        let result = Python::try_attach(|py| spawn_accepted_transport_with_py(py, server, stream));
         match result {
             Some(Ok(_)) => {}
             Some(Err(err)) => server.report_error(err, message),
@@ -3156,13 +3155,12 @@ fn schedule_accepted_transport(server: &Arc<ServerCore>, stream: AcceptedStream,
         return;
     }
 
-    if let Err(err) = server
-        .loop_core
-        .send_command(LoopCommand::Transport(LoopTransportCommand::ServerAccepted {
+    if let Err(err) = server.loop_core.send_command(LoopCommand::Transport(
+        LoopTransportCommand::ServerAccepted {
             server: Arc::clone(server),
             stream,
-        }))
-    {
+        },
+    )) {
         server.report_error(PyRuntimeError::new_err(err.to_string()), message);
     }
 }