chore: fmt/typo

Author: PDXKimani

protosocket-connection/src/connection.rs

@@ -152,10 +152,13 @@ where
     /// ensure buffer state and read from the inbound stream
     fn poll_read_inbound(&mut self, context: &mut Context<'_>) -> ReadBufferState {
         if self.receive_buffer.len() < self.max_buffer_length
-            && self.receive_buffer.len() - self.receive_buffer_unread_index < self.buffer_allocation_increment
+            && self.receive_buffer.len() - self.receive_buffer_unread_index
+                < self.buffer_allocation_increment
         {
-            self.receive_buffer
-                .resize(self.receive_buffer.len() + self.buffer_allocation_increment, 0);
+            self.receive_buffer.resize(
+                self.receive_buffer.len() + self.buffer_allocation_increment,
+                0,
+            );
         }
 
         if 0 < self.receive_buffer.len() - self.receive_buffer_unread_index {

protosocket-prost/src/prost_client_registry.rs

@@ -9,7 +9,7 @@ use crate::{ProstClientConnectionBindings, ProstSerializer};
 #[derive(Debug, Clone)]
 pub struct ClientRegistry<TConnector = TcpConnector> {
     max_buffer_length: usize,
-    buffer_allocation_interval: usize,
+    buffer_allocation_increment: usize,
     max_queued_outbound_messages: usize,
     runtime: tokio::runtime::Handle,
     stream_connector: TConnector,
@@ -45,7 +45,7 @@ where
         Self {
             max_buffer_length: 4 * (1 << 20),
             max_queued_outbound_messages: 256,
-            buffer_allocation_interval: 1 << 20,
+            buffer_allocation_increment: 1 << 20,
             runtime,
             stream_connector: connector,
         }
@@ -93,7 +93,7 @@ where
             ProstSerializer::default(),
             ProstSerializer::default(),
             self.max_buffer_length,
-            self.buffer_allocation_interval,
+            self.buffer_allocation_increment,
             self.max_queued_outbound_messages,
             outbound_messages,
             message_reactor,

protosocket-rpc/src/client/configuration.rs

@@ -170,7 +170,7 @@ impl tokio_rustls::rustls::client::danger::ServerCertVerifier for DoNothingVerif
 #[derive(Debug, Clone)]
 pub struct Configuration<TStreamConnector> {
     max_buffer_length: usize,
-    buffer_allocation_interval: usize,
+    buffer_allocation_increment: usize,
     max_queued_outbound_messages: usize,
     stream_connector: TStreamConnector,
 }
@@ -183,7 +183,7 @@ where
         log::trace!("new client configuration");
         Self {
             max_buffer_length: 4 * (1 << 20), // 4 MiB
-            buffer_allocation_interval: 1 << 20,
+            buffer_allocation_increment: 1 << 20,
             max_queued_outbound_messages: 256,
             stream_connector,
         }
@@ -206,8 +206,8 @@ where
     /// Amount of buffer to allocate at one time when buffer needs extension.
     ///
     /// Default: 1MiB
-    pub fn buffer_allocation_interval(&mut self, buffer_allocation_interval: usize) {
-        self.buffer_allocation_interval = buffer_allocation_interval;
+    pub fn buffer_allocation_increment(&mut self, buffer_allocation_increment: usize) {
+        self.buffer_allocation_increment = buffer_allocation_increment;
     }
 }
 
@@ -256,7 +256,7 @@ where
         Deserializer::default(),
         Serializer::default(),
         configuration.max_buffer_length,
-        configuration.buffer_allocation_interval,
+        configuration.buffer_allocation_increment,
         configuration.max_queued_outbound_messages,
         outbound_messages,
         message_reactor,

protosocket-server/src/connection_server.rs

@@ -57,7 +57,7 @@ pub struct ProtosocketServer<Connector: ServerConnector> {
     connector: Connector,
     listener: tokio::net::TcpListener,
     max_buffer_length: usize,
-    buffer_allocation_interval: usize,
+    buffer_allocation_increment: usize,
     max_queued_outbound_messages: usize,
     runtime: tokio::runtime::Handle,
 }
@@ -79,7 +79,7 @@ impl<Connector: ServerConnector> ProtosocketServer<Connector> {
             listener,
             max_buffer_length: 16 * (2 << 20),
             max_queued_outbound_messages: 128,
-            buffer_allocation_interval: 1 << 20,
+            buffer_allocation_increment: 1 << 20,
             runtime,
         })
     }
@@ -116,7 +116,7 @@ impl<Connector: ServerConnector> Future for ProtosocketServer<Connector> {
                             self.connector.deserializer(),
                             self.connector.serializer(),
                             self.max_buffer_length,
-                            self.buffer_allocation_interval,
+                            self.buffer_allocation_increment,
                             self.max_queued_outbound_messages,
                             outbound_messages,
                             reactor,