Fix style

Signed-off-by: Michael X. Grey <[email protected]>

Author: mxgrey

src/buffer/any_buffer.rs

@@ -389,7 +389,10 @@ impl<'w, 's, 'a> AnyBufferMut<'w, 's, 'a> {
     /// If the input value does not match the message type of the buffer, this
     /// will return [`Err`] and give back an error with the message that you
     /// tried to push and the type information for the expected message type.
-    pub fn push_any(&mut self, value: AnyMessageBox) -> Result<Option<AnyMessageBox>, AnyMessageError> {
+    pub fn push_any(
+        &mut self,
+        value: AnyMessageBox,
+    ) -> Result<Option<AnyMessageBox>, AnyMessageError> {
         self.storage.any_push(self.session, value)
     }
 
@@ -525,7 +528,8 @@ trait AnyBufferViewing {
 
 trait AnyBufferManagement: AnyBufferViewing {
     fn any_push(&mut self, session: Entity, value: AnyMessageBox) -> AnyMessagePushResult;
-    fn any_push_as_oldest(&mut self, session: Entity, value: AnyMessageBox) -> AnyMessagePushResult;
+    fn any_push_as_oldest(&mut self, session: Entity, value: AnyMessageBox)
+        -> AnyMessagePushResult;
     fn any_pull(&mut self, session: Entity) -> Option<AnyMessageBox>;
     fn any_pull_newest(&mut self, session: Entity) -> Option<AnyMessageBox>;
     fn any_oldest_mut<'a>(&'a mut self, session: Entity) -> Option<AnyMessageMut<'a>>;
@@ -675,7 +679,11 @@ impl<T: 'static + Send + Sync + Any> AnyBufferManagement for Mut<'_, BufferStora
         Ok(self.push(session, value).map(to_any_message))
     }
 
-    fn any_push_as_oldest(&mut self, session: Entity, value: AnyMessageBox) -> AnyMessagePushResult {
+    fn any_push_as_oldest(
+        &mut self,
+        session: Entity,
+        value: AnyMessageBox,
+    ) -> AnyMessagePushResult {
         let value = from_any_message::<T>(value)?;
         Ok(self.push_as_oldest(session, value).map(to_any_message))
     }
@@ -721,7 +729,9 @@ fn to_any_message<T: 'static + Send + Sync + Any>(x: T) -> AnyMessageBox {
     Box::new(x)
 }
 
-fn from_any_message<T: 'static + Send + Sync + Any>(value: AnyMessageBox) -> Result<T, AnyMessageError>
+fn from_any_message<T: 'static + Send + Sync + Any>(
+    value: AnyMessageBox,
+) -> Result<T, AnyMessageError>
 where
     T: 'static,
 {

src/buffer/buffer_map.rs

@@ -24,9 +24,9 @@ use smallvec::SmallVec;
 use bevy_ecs::prelude::{Entity, World};
 
 use crate::{
-    add_listener_to_source, Accessed, AddOperation, AnyBuffer, AnyBufferKey, AnyMessageBox,
-    Buffer, BufferKeyBuilder, Buffered, Builder, Chain, Gate, GateState, Join, Joined,
-    OperationError, OperationResult, OperationRoster, Output, UnusedTarget, Bufferable,
+    add_listener_to_source, Accessed, AddOperation, AnyBuffer, AnyBufferKey, AnyMessageBox, Buffer,
+    BufferKeyBuilder, Bufferable, Buffered, Builder, Chain, Gate, GateState, Join, Joined,
+    OperationError, OperationResult, OperationRoster, Output, UnusedTarget,
 };
 
 #[derive(Clone, Default)]
@@ -59,7 +59,11 @@ pub struct IncompatibleLayout {
 
 impl IncompatibleLayout {
     /// Check whether a named buffer is compatible with a specific concrete message type.
-    pub fn require_message_type<Message: 'static>(&mut self, expected_name: &str, buffers: &BufferMap) -> Result<Buffer<Message>, ()> {
+    pub fn require_message_type<Message: 'static>(
+        &mut self,
+        expected_name: &str,
+        buffers: &BufferMap,
+    ) -> Result<Buffer<Message>, ()> {
         if let Some((name, buffer)) = buffers.inner.get_key_value(expected_name) {
             if let Some(buffer) = buffer.downcast_for_message::<Message>() {
                 return Ok(buffer);
@@ -80,7 +84,11 @@ impl IncompatibleLayout {
 
     /// Check whether a named buffer is compatible with a specialized buffer type,
     /// such as `JsonBuffer`.
-    pub fn require_buffer_type<BufferType: 'static>(&mut self, expected_name: &str, buffers: &BufferMap) -> Result<BufferType, ()> {
+    pub fn require_buffer_type<BufferType: 'static>(
+        &mut self,
+        expected_name: &str,
+        buffers: &BufferMap,
+    ) -> Result<BufferType, ()> {
         if let Some((name, buffer)) = buffers.inner.get_key_value(expected_name) {
             if let Some(buffer) = buffer.downcast_buffer::<BufferType>() {
                 return Ok(buffer);
@@ -139,11 +147,7 @@ impl<T: BufferMapLayout> Buffered for T {
         }
     }
 
-    fn buffered_count(
-        &self,
-        session: Entity,
-        world: &World,
-    ) -> Result<usize, OperationError> {
+    fn buffered_count(&self, session: Entity, world: &World) -> Result<usize, OperationError> {
         let mut min_count = None;
 
         for buffer in self.buffer_list() {
@@ -158,11 +162,7 @@ impl<T: BufferMapLayout> Buffered for T {
         Ok(min_count.unwrap_or(0))
     }
 
-    fn ensure_active_session(
-        &self,
-        session: Entity,
-        world: &mut World,
-    ) -> OperationResult {
+    fn ensure_active_session(&self, session: Entity, world: &mut World) -> OperationResult {
         for buffer in self.buffer_list() {
             buffer.ensure_active_session(session, world)?;
         }
@@ -238,7 +238,7 @@ pub trait JoinedValue: 'static + Send + Sync + Sized {
 
 /// Trait to describe a layout of buffer keys
 pub trait BufferKeyMap: 'static + Send + Sync + Sized + Clone {
-    type Buffers: 'static + BufferMapLayout + Accessed<Key=Self> + Send + Sync;
+    type Buffers: 'static + BufferMapLayout + Accessed<Key = Self> + Send + Sync;
 }
 
 impl BufferMapLayout for BufferMap {
@@ -402,10 +402,7 @@ mod tests {
                 |chain: Chain<_>| chain.connect(buffer_string.input_slot()),
             ));
 
-            builder
-                .try_join(&buffers)
-                .unwrap()
-                .connect(scope.terminate);
+            builder.try_join(&buffers).unwrap().connect(scope.terminate);
         });
 
         let mut promise = context.command(|commands| {
@@ -439,9 +436,7 @@ mod tests {
                 |chain: Chain<_>| chain.connect(buffers.string.input_slot()),
             ));
 
-            builder
-                .join(buffers)
-                .connect(scope.terminate);
+            builder.join(buffers).connect(scope.terminate);
         });
 
         let mut promise = context.command(|commands| {

src/buffer/bufferable.rs

@@ -19,8 +19,8 @@ use bevy_utils::all_tuples;
 use smallvec::SmallVec;
 
 use crate::{
-    Accessed, AddOperation, Buffer, BufferSettings, Buffered, Builder, Chain,
-    CloneFromBuffer, Join, Joined, Output, UnusedTarget,
+    Accessed, AddOperation, Buffer, BufferSettings, Buffered, Builder, Chain, CloneFromBuffer,
+    Join, Joined, Output, UnusedTarget,
 };
 
 pub type BufferKeys<B> = <<B as Bufferable>::BufferType as Accessed>::Key;

src/buffer/buffered.rs

@@ -22,11 +22,10 @@ use bevy_utils::all_tuples;
 use smallvec::SmallVec;
 
 use crate::{
-    Buffer, BufferAccessors, BufferKey, BufferKeyBuilder, BufferStorage, CloneFromBuffer,
-    ForkTargetStorage, Gate, GateState, InspectBuffer, ManageBuffer, OperationError,
-    OperationResult, OperationRoster, OrBroken, SingleInputStorage, Join, Output,
-    AddOperation, Chain, Builder, UnusedTarget, Listen, CleanupWorkflowConditions,
-    Scope, ScopeSettings, BeginCleanupWorkflow,
+    AddOperation, BeginCleanupWorkflow, Buffer, BufferAccessors, BufferKey, BufferKeyBuilder,
+    BufferStorage, Builder, Chain, CleanupWorkflowConditions, CloneFromBuffer, ForkTargetStorage,
+    Gate, GateState, InspectBuffer, Join, Listen, ManageBuffer, OperationError, OperationResult,
+    OperationRoster, OrBroken, Output, Scope, ScopeSettings, SingleInputStorage, UnusedTarget,
 };
 
 pub trait Buffered: 'static + Send + Sync + Clone {
@@ -110,7 +109,6 @@ pub trait Accessed: Buffered {
         Output::new(scope, target).chain(builder)
     }
 
-
     /// Alternative way to call [`Builder::on_cleanup`].
     fn on_cleanup<Settings>(
         self,

src/buffer/json_buffer.rs

@@ -1404,7 +1404,11 @@ mod tests {
     impl crate::Joined for TestJoinedValueJsonBuffers {
         type Item = TestJoinedValueJson;
 
-        fn pull(&self, session: Entity, world: &mut World) -> Result<Self::Item, crate::OperationError> {
+        fn pull(
+            &self,
+            session: Entity,
+            world: &mut World,
+        ) -> Result<Self::Item, crate::OperationError> {
             let integer = self.integer.pull(session, world)?;
             let float = self.float.pull(session, world)?;
             let json = self.json.pull(session, world)?;
@@ -1443,10 +1447,7 @@ mod tests {
                 |chain: Chain<_>| chain.connect(buffer_json.input_slot()),
             ));
 
-            builder
-                .try_join(&buffers)
-                .unwrap()
-                .connect(scope.terminate);
+            builder.try_join(&buffers).unwrap().connect(scope.terminate);
         });
 
         let mut promise = context.command(|commands| {
@@ -1484,9 +1485,7 @@ mod tests {
                 |chain: Chain<_>| chain.connect(json_buffer.input_slot()),
             ));
 
-            builder
-                .join(buffers)
-                .connect(scope.terminate);
+            builder.join(buffers).connect(scope.terminate);
         });
 
         let mut promise = context.command(|commands| {

src/builder.rs

@@ -22,14 +22,13 @@ use std::future::Future;
 use smallvec::SmallVec;
 
 use crate::{
-    AddOperation, AsMap, Buffer, BufferKeys, BufferLocation, BufferMap,
-    BufferSettings, Bufferable, Buffered, Chain, Collect, ForkClone, ForkCloneOutput,
-    ForkTargetStorage, Gate, GateRequest, IncompatibleLayout, Injection, InputSlot, IntoAsyncMap,
-    IntoBlockingMap, JoinedItem, JoinedValue, Node, OperateBuffer, OperateBufferAccess,
-    OperateDynamicGate, OperateScope, OperateSplit, OperateStaticGate, Output, Provider,
-    RequestOfMap, ResponseOfMap, Scope, ScopeEndpoints, ScopeSettings, ScopeSettingsStorage,
-    Sendish, Service, SplitOutputs, Splittable, StreamPack, StreamTargetMap, StreamsOfMap, Trim,
-    TrimBranch, UnusedTarget, Joined, Accessed,
+    Accessed, AddOperation, AsMap, Buffer, BufferKeys, BufferLocation, BufferMap, BufferSettings,
+    Bufferable, Buffered, Chain, Collect, ForkClone, ForkCloneOutput, ForkTargetStorage, Gate,
+    GateRequest, IncompatibleLayout, Injection, InputSlot, IntoAsyncMap, IntoBlockingMap, Joined,
+    JoinedItem, JoinedValue, Node, OperateBuffer, OperateBufferAccess, OperateDynamicGate,
+    OperateScope, OperateSplit, OperateStaticGate, Output, Provider, RequestOfMap, ResponseOfMap,
+    Scope, ScopeEndpoints, ScopeSettings, ScopeSettingsStorage, Sendish, Service, SplitOutputs,
+    Splittable, StreamPack, StreamTargetMap, StreamsOfMap, Trim, TrimBranch, UnusedTarget,
 };
 
 pub(crate) mod connect;
@@ -456,7 +455,9 @@ impl<'w, 's, 'a> Builder<'w, 's, 'a> {
         B::BufferType: Accessed,
         Settings: Into<ScopeSettings>,
     {
-        from_buffers.into_buffer(self).on_cleanup_if(self, conditions, build);
+        from_buffers
+            .into_buffer(self)
+            .on_cleanup_if(self, conditions, build);
     }
 
     /// Create a node that trims (cancels) other nodes in the workflow when it

src/lib.rs

@@ -336,10 +336,10 @@ impl Plugin for ImpulsePlugin {
 pub mod prelude {
     pub use crate::{
         buffer::{
-            Accessible, AnyBuffer, AnyBufferKey, AnyBufferMut, AnyBufferWorldAccess, AnyMessageBox, Buffer,
-            BufferAccess, BufferAccessMut, BufferKey, BufferKeyMap, BufferMap, BufferMapLayout,
-            BufferSettings, Bufferable, Buffered, IncompatibleLayout, IterBufferable, Joinable, JoinedValue,
-            RetentionPolicy,
+            Accessible, AnyBuffer, AnyBufferKey, AnyBufferMut, AnyBufferWorldAccess, AnyMessageBox,
+            Buffer, BufferAccess, BufferAccessMut, BufferKey, BufferKeyMap, BufferMap,
+            BufferMapLayout, BufferSettings, Bufferable, Buffered, IncompatibleLayout,
+            IterBufferable, Joinable, JoinedValue, RetentionPolicy,
         },
         builder::Builder,
         callback::{AsCallback, Callback, IntoAsyncCallback, IntoBlockingCallback},