Struct tokio_test::task::Spawn

pub struct Spawn<T> { /* fields omitted */ }

Future spawned on a mock task

Methods

impl<T> Spawn<T>

pub fn into_inner(self) -> T where
    T: Unpin, 

Consumes self returning the inner value

pub fn is_woken(&self) -> bool

Returns true if the inner future has received a wake notification since the last call to enter.

pub fn waker_ref_count(&self) -> usize

Returns the number of references to the task waker

The task itself holds a reference. The return value will never be zero.

pub fn enter<F, R>(&mut self, f: F) -> R where
    F: FnOnce(&mut Context, Pin<&mut T>) -> R, 

Enter the task context

impl<T: Future> Spawn<T>

pub fn poll(&mut self) -> Poll<T::Output>

Polls a future

impl<T: Stream> Spawn<T>

pub fn poll_next(&mut self) -> Poll<Option<T::Item>>

Polls a stream

Trait Implementations

impl<T: Debug> Debug for Spawn<T>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T: Unpin> Deref for Spawn<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &T

Dereferences the value.

impl<T: Unpin> DerefMut for Spawn<T>

fn deref_mut(&mut self) -> &mut T

Mutably dereferences the value.

impl<T: Future> Future for Spawn<T>

type Output = T::Output

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<T: Stream> Stream for Spawn<T>

type Item = T::Item

Values yielded by the stream.

fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.