Format and clippy

deib-polimi · May 27, 2024 · 0d17625 · 0d17625
1 parent b989c6a
commit 0d17625
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -151,6 +151,6 @@ pub mod prelude {
     pub use super::operator::window::{CountWindow, ProcessingTimeWindow, SessionWindow};
     #[cfg(feature = "timestamp")]
     pub use super::operator::window::{EventTimeWindow, TransactionWindow};
-    pub use super::{BatchMode, RuntimeConfig, StreamContext};
     pub use super::Replication;
+    pub use super::{BatchMode, RuntimeConfig, StreamContext};
 }
diff --git a/src/operator/source/avro.rs b/src/operator/source/avro.rs
@@ -140,7 +140,7 @@ impl<R: MakeReader + Clone> Clone for AvroSource<R> {
         Self {
             reader: None,
             terminated: false,
-            replication: self.replication.clone(),
+            replication: self.replication,
             make_reader: self.make_reader.clone(),
         }
     }
@@ -174,7 +174,9 @@ impl<Op> Stream<Op>
 where
     Op: Operator<Out = Value> + 'static,
 {
-    pub fn from_avro_value<T: for<'de> Deserialize<'de> + Send>(self) -> Stream<impl Operator<Out = T>> {
+    pub fn from_avro_value<T: for<'de> Deserialize<'de> + Send>(
+        self,
+    ) -> Stream<impl Operator<Out = T>> {
         self.map(|v| {
             let de = from_value(&v);
             de.expect("failed to deserialize")