cargo fmt

Author: carlsverre

lib/sqlsync/src/coordinator.rs

@@ -127,7 +127,8 @@ impl<J: Journal, R: Reducer> CoordinatorDocument<J, R> {
 
 /// CoordinatorDocument knows how to replicate it's storage journal
 impl<J: Journal + ReplicationSource, R> ReplicationSource for CoordinatorDocument<J, R> {
-    type Reader<'a> = <J as ReplicationSource>::Reader<'a>
+    type Reader<'a>
+        = <J as ReplicationSource>::Reader<'a>
     where
         Self: 'a;
 

lib/sqlsync/src/journal/memory.rs

@@ -73,7 +73,8 @@ impl Journal for MemoryJournal {
 }
 
 impl Scannable for MemoryJournal {
-    type Reader<'a> = &'a [u8]
+    type Reader<'a>
+        = &'a [u8]
     where
         Self: 'a;
 
@@ -95,7 +96,8 @@ impl Scannable for MemoryJournal {
 }
 
 impl ReplicationSource for MemoryJournal {
-    type Reader<'a> = &'a [u8]
+    type Reader<'a>
+        = &'a [u8]
     where
         Self: 'a;
 

lib/sqlsync/src/local.rs

@@ -132,7 +132,8 @@ where
 
 /// LocalDocument knows how to send it's timeline journal elsewhere
 impl<J: ReplicationSource, S> ReplicationSource for LocalDocument<J, S> {
-    type Reader<'a> = <J as ReplicationSource>::Reader<'a>
+    type Reader<'a>
+        = <J as ReplicationSource>::Reader<'a>
     where
         Self: 'a;
 

lib/sqlsync/src/storage.rs

@@ -346,7 +346,8 @@ impl<J: Journal> Storage<J> {
 }
 
 impl<J: ReplicationSource> ReplicationSource for Storage<J> {
-    type Reader<'a> = <J as ReplicationSource>::Reader<'a>
+    type Reader<'a>
+        = <J as ReplicationSource>::Reader<'a>
     where
         Self: 'a;