Automatic formatting with rustfmt

constellation-rs · May 22, 2020 · 9f8476e · 9f8476e
1 parent 6d97618
commit 9f8476e
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/amadeus-core/src/dist_iter.rs b/amadeus-core/src/dist_iter.rs
@@ -176,7 +176,6 @@ pub trait DistributedIterator {
 				let reduce1 = reduce1factory.make();
 				pool.spawn(FnOnce!(move || -> <R1 as ReducerA>::Output {
 					futures::executor::block_on(futures::future::poll_fn(|cx| {
-
 						#[pin_project]
 						struct Connect<A, B>(#[pin] A, #[pin] B);
 						impl<A, B> ConsumerAsync for Connect<A, B>
@@ -186,7 +185,8 @@ pub trait DistributedIterator {
 						{
 							type Item = B::Item;
 							fn poll_run(
-								self: Pin<&mut Self>, cx: &mut Context, sink: Pin<&mut impl Sink<Self::Item>>,
+								self: Pin<&mut Self>, cx: &mut Context,
+								sink: Pin<&mut impl Sink<Self::Item>>,
 							) -> Poll<()> {
 								#[pin_project]
 								struct Proxy<'a, I, B>(#[pin] I, Pin<&'a mut B>);
@@ -214,7 +214,6 @@ pub trait DistributedIterator {
 						// pin_mut!(task);
 
 						todo!()
-
 					}))
 					// #[pin_project]
 					// struct Connect<I, R>(I, #[pin] R);