From 69e8df9d6214f1b66d04bebd6588558c11bacce2 Mon Sep 17 00:00:00 2001 From: Jonathas-Conceicao Date: Sat, 4 Apr 2020 19:03:53 -0300 Subject: [PATCH] actix-rt: Run rustfmt Signed-off-by: Jonathas-Conceicao --- actix-rt/src/arbiter.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/actix-rt/src/arbiter.rs b/actix-rt/src/arbiter.rs index c8c49775..b9fbc51a 100644 --- a/actix-rt/src/arbiter.rs +++ b/actix-rt/src/arbiter.rs @@ -8,7 +8,10 @@ use std::{fmt, thread}; use futures_channel::mpsc::{unbounded, UnboundedReceiver, UnboundedSender}; use futures_channel::oneshot::{channel, Canceled, Sender}; -use futures_util::{future::{self, Future, FutureExt}, stream::Stream}; +use futures_util::{ + future::{self, Future, FutureExt}, + stream::Stream, +}; use crate::runtime::Runtime; use crate::system::System; @@ -180,8 +183,7 @@ impl Arbiter { // Box the future and push it to the queue, this results in double boxing // because the executor boxes the future again, but works for now Q.with(move |cell| { - cell.borrow_mut() - .push(Pin::from(Box::alloc().init(future))) + cell.borrow_mut().push(Pin::from(Box::alloc().init(future))) }); } });