Files

futures

lib.rs

futures_channel

mpsc

mod.rsqueue.rs

lib.rslock.rsoneshot.rs

futures_core

future

future_obj.rsmod.rs

stream

mod.rsstream_obj.rs

task

__internal

atomic_waker.rsmod.rs

mod.rsspawn.rs

lib.rs

futures_executor

enter.rslib.rslocal_pool.rsthread_pool.rsunpark_mutex.rs

futures_io

lib.rs

futures_select_macro

lib.rs

futures_sink

channel_impls.rslib.rs

futures_test

future

assert_unmoved.rsmod.rspending_once.rs

task

mod.rsnoop_spawner.rspanic_spawner.rspanic_waker.rsrecord_spawner.rswake_counter.rs

assert.rslib.rs

futures_util

async_await

join.rsmod.rspending.rspoll.rsselect_mod.rs

compat

compat01as03.rscompat03as01.rsexecutor.rsmod.rs

future

abortable.rscatch_unwind.rschain.rsempty.rsflatten.rsflatten_stream.rsfuse.rsinspect.rsinto_stream.rsjoin.rsjoin_all.rslazy.rsmap.rsmaybe_done.rsmod.rsoption.rspoll_fn.rsready.rsremote_handle.rsshared.rsthen.rsunit_error.rs

io

allow_std.rsclose.rscopy_into.rsflush.rsmod.rsread.rsread_exact.rsread_to_end.rssplit.rswindow.rswrite_all.rs

lock

bilock.rsmod.rsmutex.rs

macros

mod.rspoll.rs

sink

buffer.rsclose.rsdrain.rserr_into.rsfanout.rsflush.rsmap_err.rsmod.rssend.rssend_all.rswith.rswith_flat_map.rs

stream

futures_unordered

abort.rsiter.rsmod.rsready_to_run_queue.rstask.rs

buffer_unordered.rsbuffered.rscatch_unwind.rschain.rschunks.rscollect.rsconcat.rsempty.rsfilter.rsfilter_map.rsflatten.rsfold.rsfor_each.rsfor_each_concurrent.rsforward.rsfuse.rsfutures_ordered.rsinspect.rsinto_future.rsiter.rsmap.rsmod.rsnext.rsonce.rspeek.rspoll_fn.rsrepeat.rsselect.rsselect_all.rsselect_next_some.rsskip.rsskip_while.rssplit.rstake.rstake_while.rsthen.rsunfold.rszip.rs

task

arc_wake.rsmod.rsnoop_waker.rsspawn.rswaker_ref.rs

try_future

and_then.rserr_into.rsflatten_sink.rsinto_future.rsmap_err.rsmap_ok.rsmod.rsor_else.rstry_chain.rstry_join.rstry_join_all.rsunwrap_or_else.rs

try_stream

err_into.rsinto_async_read.rsinto_stream.rsmap_err.rsmap_ok.rsmod.rstry_buffer_unordered.rstry_collect.rstry_concat.rstry_filter_map.rstry_fold.rstry_for_each.rstry_for_each_concurrent.rstry_next.rstry_skip_while.rs

lib.rs

>

//! Task notification.

mod spawn;
#[doc(hidden)]
pub mod __internal;
pub use self::spawn::{Spawn, LocalSpawn, SpawnError};

pub use core::task::{Poll, Waker, RawWaker, RawWakerVTable};