fmt

dojoengine · Oct 17, 2024 · cf370b6 · cf370b6
1 parent 494307e
commit cf370b6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 5 deletions.
diff --git a/crates/torii/client/src/client/mod.rs b/crates/torii/client/src/client/mod.rs
@@ -13,7 +13,9 @@ use starknet::providers::jsonrpc::HttpTransport;
 use starknet::providers::JsonRpcClient;
 use tokio::sync::RwLock as AsyncRwLock;
 use torii_grpc::client::{EventUpdateStreaming, IndexerUpdateStreaming};
-use torii_grpc::proto::world::{RetrieveEntitiesResponse, RetrieveEventsResponse, SubscribeEntityResponse};
+use torii_grpc::proto::world::{
+    RetrieveEntitiesResponse, RetrieveEventsResponse, SubscribeEntityResponse,
+};
 use torii_grpc::types::schema::Entity;
 use torii_grpc::types::{EntityKeysClause, Event, EventQuery, KeysClause, Query};
 use torii_relay::client::EventLoop;
@@ -130,7 +132,9 @@ impl Client {
         Ok(EntityUpdateStreaming(stream.map_ok(Box::new(move |res| {
             res.entity.map_or(
                 (res.subscription_id, Entity { hashed_keys: Felt::ZERO, models: vec![] }),
-                |entity| (res.subscription_id, entity.map(&models).expect("must able to serialize"))
+                |entity| {
+                    (res.subscription_id, entity.map(&models).expect("must able to serialize"))
+                },
             )
         }))))
     }
@@ -158,7 +162,9 @@ impl Client {
         Ok(EntityUpdateStreaming(stream.map_ok(Box::new(move |res| {
             res.entity.map_or(
                 (res.subscription_id, Entity { hashed_keys: Felt::ZERO, models: vec![] }),
-                |entity| (res.subscription_id, entity.map(&models).expect("must able to serialize"))
+                |entity| {
+                    (res.subscription_id, entity.map(&models).expect("must able to serialize"))
+                },
             )
         }))))
     }

diff --git a/crates/torii/grpc/src/client.rs b/crates/torii/grpc/src/client.rs
@@ -14,9 +14,8 @@ use crate::proto::world::{
     RetrieveEventsResponse, SubscribeEntitiesRequest, SubscribeEntityResponse,
     SubscribeEventsRequest, SubscribeEventsResponse, SubscribeIndexerRequest,
     SubscribeIndexerResponse, SubscribeModelsRequest, SubscribeModelsResponse,
-    UpdateEntitiesSubscriptionRequest, WorldMetadataRequest
+    UpdateEntitiesSubscriptionRequest, WorldMetadataRequest,
 };
-
 use crate::types::schema::SchemaError;
 use crate::types::{
     EntityKeysClause, Event, EventQuery, IndexerUpdate, KeysClause, ModelKeysClause, Query,