Rustfmt down to 80 characters

Author: Nemo157

.rustfmt.toml

@@ -0,0 +1,2 @@
+max_width = 80
+comment_width = 80

futures-util/src/compat/compat01to03.rs

@@ -12,7 +12,10 @@ use std::mem::PinMut;
 impl<Fut: Future01> Future03 for Compat<Fut, ()> {
     type Output = Result<Fut::Item, Fut::Error>;
 
-    fn poll(self: PinMut<Self>, cx: &mut task03::Context) -> task03::Poll<Self::Output> {
+    fn poll(
+        self: PinMut<Self>,
+        cx: &mut task03::Context,
+    ) -> task03::Poll<Self::Output> {
         let notify = &WakerToHandle(cx.waker());
 
         executor01::with_notify(notify, 0, move || {
@@ -28,7 +31,10 @@ impl<Fut: Future01> Future03 for Compat<Fut, ()> {
 impl<St: Stream01> Stream03 for Compat<St, ()> {
     type Item = Result<St::Item, St::Error>;
 
-    fn poll_next(self: PinMut<Self>, cx: &mut task03::Context) -> task03::Poll<Option<Self::Item>> {
+    fn poll_next(
+        self: PinMut<Self>,
+        cx: &mut task03::Context,
+    ) -> task03::Poll<Option<Self::Item>> {
         let notify = &WakerToHandle(cx.waker());
 
         executor01::with_notify(notify, 0, move || {

futures-util/src/compat/compat03to01.rs

@@ -1,9 +1,12 @@
 use super::Compat;
 use futures::{
-    task as task01, Async as Async01, AsyncSink as AsyncSink01, Future as Future01, Poll as Poll01,
-    Sink as Sink01, StartSend as StartSend01, Stream as Stream01,
+    task as task01, Async as Async01, AsyncSink as AsyncSink01,
+    Future as Future01, Poll as Poll01, Sink as Sink01,
+    StartSend as StartSend01, Stream as Stream01,
+};
+use futures_core::{
+    task as task03, TryFuture as TryFuture03, TryStream as TryStream03,
 };
-use futures_core::{task as task03, TryFuture as TryFuture03, TryStream as TryStream03};
 use futures_sink::Sink as Sink03;
 use std::{marker::Unpin, mem::PinMut, sync::Arc};
 
@@ -50,10 +53,15 @@ where
     type SinkItem = T::SinkItem;
     type SinkError = T::SinkError;
 
-    fn start_send(&mut self, item: Self::SinkItem) -> StartSend01<Self::SinkItem, Self::SinkError> {
+    fn start_send(
+        &mut self,
+        item: Self::SinkItem,
+    ) -> StartSend01<Self::SinkItem, Self::SinkError> {
         with_context(self, |mut inner, cx| {
             match inner.reborrow().poll_ready(cx) {
-                task03::Poll::Ready(Ok(())) => inner.start_send(item).map(|()| AsyncSink01::Ready),
+                task03::Poll::Ready(Ok(())) => {
+                    inner.start_send(item).map(|()| AsyncSink01::Ready)
+                }
                 task03::Poll::Pending => Ok(AsyncSink01::NotReady(item)),
                 task03::Poll::Ready(Err(e)) => Err(e),
             }
@@ -97,6 +105,7 @@ where
     F: FnOnce(PinMut<T>, &mut task03::Context) -> R,
 {
     let waker = current_as_waker();
-    let mut cx = task03::Context::new(&waker, compat.executor.as_mut().unwrap());
+    let executor = compat.executor.as_mut().unwrap();
+    let mut cx = task03::Context::new(&waker, executor);
     f(PinMut::new(&mut compat.inner), &mut cx)
 }