chore: fmt

Author: Frando

src/api/actor.rs

@@ -1,17 +1,15 @@
 use std::sync::Arc;
 
-use irpc::LocalSender;
-use irpc::WithChannels;
+use irpc::{LocalSender, WithChannels};
 use n0_future::task::{self};
 use tokio::sync::mpsc as tokio_mpsc;
 use tracing::error;
 
-use crate::engine::Engine;
-
 use super::{
     protocol::{DocsMessage, DocsService},
     DocsApi,
 };
+use crate::engine::Engine;
 
 /// The docs RPC actor that handles incoming messages
 pub(crate) struct RpcActor {

src/api/api.rs

@@ -8,14 +8,12 @@ use anyhow::{Context, Result};
 use irpc::rpc::Handler;
 use n0_future::task::{self, AbortOnDropHandle};
 
-use crate::engine::Engine;
-
+pub use self::client::*;
 use super::{
     actor::RpcActor,
     protocol::{DocsMessage, DocsProtocol, DocsService},
 };
-
-pub use self::client::*;
+use crate::engine::Engine;
 
 type Client = irpc::Client<DocsMessage, DocsProtocol, DocsService>;
 
@@ -100,6 +98,7 @@ mod client {
     };
     use n0_future::{FutureExt, Stream, StreamExt};
 
+    use super::{Client, DocsApi};
     use crate::{
         actor::OpenState,
         api::protocol::{
@@ -116,8 +115,6 @@ mod client {
         Author, AuthorId, Capability, CapabilityKind, DocTicket, Entry, NamespaceId, PeerIdBytes,
     };
 
-    use super::{Client, DocsApi};
-
     impl DocsApi {
         /// Creates a new document author.
         ///

src/api/protocol.rs

@@ -11,6 +11,7 @@ use irpc::{
 };
 use serde::{Deserialize, Serialize};
 
+use super::RpcResult;
 use crate::{
     actor::OpenState,
     engine::LiveEvent,
@@ -19,8 +20,6 @@ use crate::{
     SignedEntry,
 };
 
-use super::RpcResult;
-
 /// The RPC service type for the docs protocol.
 #[derive(Debug, Clone, Copy)]
 pub struct DocsService;

tests/client.rs

@@ -1,8 +1,4 @@
 #![cfg(feature = "rpc")]
-use self::util::{
-    path::{key_to_path, path_to_key},
-    Node,
-};
 use anyhow::{Context, Result};
 use futures_util::TryStreamExt;
 use iroh_blobs::api::blobs::{ExportMode, ImportMode};
@@ -12,6 +8,11 @@ use testresult::TestResult;
 use tokio::io::AsyncWriteExt;
 use tracing_test::traced_test;
 
+use self::util::{
+    path::{key_to_path, path_to_key},
+    Node,
+};
+
 mod util;
 
 /// Test that closing a doc does not close other instances.