From a0d2651e38adb97e0fb9f0527f8c1105623e8e44 Mon Sep 17 00:00:00 2001 From: Jeb Rosen Date: Sun, 8 Sep 2019 13:56:57 -0700 Subject: [PATCH] Fix a few unused import warnings. --- core/lib/src/rocket.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/core/lib/src/rocket.rs b/core/lib/src/rocket.rs index 9275b42b..550dd95e 100644 --- a/core/lib/src/rocket.rs +++ b/core/lib/src/rocket.rs @@ -64,7 +64,7 @@ fn hyper_service_fn( // because the response body might borrow from the request. Instead, // we do the body writing in another future that will send us // the response metadata (and a body channel) beforehand. - let (tx, rx) = futures::channel::oneshot::channel(); + let (tx, rx) = oneshot::channel(); spawn.spawn(async move { // Get all of the information from Hyper. @@ -105,7 +105,7 @@ impl Rocket { fn issue_response<'r>( &self, response: Response<'r>, - tx: futures::channel::oneshot::Sender>, + tx: oneshot::Sender>, ) -> impl Future + 'r { let result = self.write_response(response, tx); async move { @@ -124,7 +124,7 @@ impl Rocket { fn write_response<'r>( &self, mut response: Response<'r>, - tx: futures::channel::oneshot::Sender>, + tx: oneshot::Sender>, ) -> impl Future> + 'r { async move { let mut hyp_res = hyper::Response::builder(); @@ -785,6 +785,8 @@ impl Rocket { // We need to get these values before moving `self` into an `Arc`. let mut shutdown_receiver = self.shutdown_receiver .take().expect("shutdown receiver has already been used"); + + #[cfg(feature = "ctrl_c_shutdown")] let shutdown_handle = self.get_shutdown_handle(); let rocket = Arc::new(self);