From 1b00f0b9fa92daa489510b8718ce56130420795f Mon Sep 17 00:00:00 2001 From: Taylor Cramer Date: Tue, 18 Sep 2018 17:50:32 -0700 Subject: Remove spawning from task::Context --- src/liballoc/boxed.rs | 71 +++------------------------------------------------ 1 file changed, 4 insertions(+), 67 deletions(-) (limited to 'src/liballoc') diff --git a/src/liballoc/boxed.rs b/src/liballoc/boxed.rs index 11b91591593..d4cca387f06 100644 --- a/src/liballoc/boxed.rs +++ b/src/liballoc/boxed.rs @@ -60,7 +60,7 @@ use core::borrow; use core::cmp::Ordering; use core::convert::From; use core::fmt; -use core::future::{Future, FutureObj, LocalFutureObj, UnsafeFutureObj}; +use core::future::Future; use core::hash::{Hash, Hasher}; use core::iter::FusedIterator; use core::marker::{Unpin, Unsize}; @@ -68,7 +68,7 @@ use core::mem; use core::pin::Pin; use core::ops::{CoerceUnsized, Deref, DerefMut, Generator, GeneratorState}; use core::ptr::{self, NonNull, Unique}; -use core::task::{Context, Poll, Spawn, SpawnErrorKind, SpawnObjError}; +use core::task::{LocalWaker, Poll}; use raw_vec::RawVec; use str::from_boxed_utf8_unchecked; @@ -804,70 +804,7 @@ impl Generator for Box impl Future for Box { type Output = F::Output; - fn poll(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll { - F::poll(Pin::new(&mut *self), cx) - } -} - -#[unstable(feature = "futures_api", issue = "50547")] -unsafe impl<'a, T, F> UnsafeFutureObj<'a, T> for Box - where F: Future + 'a -{ - fn into_raw(self) -> *mut () { - Box::into_raw(self) as *mut () - } - - unsafe fn poll(ptr: *mut (), cx: &mut Context) -> Poll { - let ptr = ptr as *mut F; - let pin: Pin<&mut F> = Pin::new_unchecked(&mut *ptr); - F::poll(pin, cx) - } - - unsafe fn drop(ptr: *mut ()) { - drop(Box::from_raw(ptr as *mut F)) - } -} - -#[unstable(feature = "futures_api", issue = "50547")] -impl Spawn for Box - where Sp: Spawn + ?Sized -{ - fn spawn_obj( - &mut self, - future: FutureObj<'static, ()>, - ) -> Result<(), SpawnObjError> { - (**self).spawn_obj(future) - } - - fn status(&self) -> Result<(), SpawnErrorKind> { - (**self).status() - } -} - -#[unstable(feature = "futures_api", issue = "50547")] -impl<'a, F: Future + Send + 'a> From> for FutureObj<'a, ()> { - fn from(boxed: Box) -> Self { - FutureObj::new(boxed) - } -} - -#[unstable(feature = "futures_api", issue = "50547")] -impl<'a, F: Future + 'a> From> for LocalFutureObj<'a, ()> { - fn from(boxed: Box) -> Self { - LocalFutureObj::new(boxed) - } -} - -#[unstable(feature = "futures_api", issue = "50547")] -impl<'a, F: Future + Send + 'a> From>> for FutureObj<'a, ()> { - fn from(boxed: Pin>) -> Self { - FutureObj::new(boxed) - } -} - -#[unstable(feature = "futures_api", issue = "50547")] -impl<'a, F: Future + 'a> From>> for LocalFutureObj<'a, ()> { - fn from(boxed: Pin>) -> Self { - LocalFutureObj::new(boxed) + fn poll(mut self: Pin<&mut Self>, lw: &LocalWaker) -> Poll { + F::poll(Pin::new(&mut *self), lw) } } -- cgit 1.4.1-3-g733a5