Files

futures

lib.rs

futures_channel

mpsc

mod.rsqueue.rs

lib.rslock.rsoneshot.rs

futures_core

future

future_obj.rsmod.rs

stream

mod.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

context.rsmod.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.rseither.rsempty.rsflatten.rsflatten_stream.rsfuse.rsinspect.rsinto_stream.rsjoin.rsjoin_all.rslazy.rsmap.rsmaybe_done.rsmod.rsnever_error.rsoption.rspoll_fn.rsready.rsremote_handle.rsselect.rsselect_all.rsshared.rsthen.rsunit_error.rs

io

allow_std.rsclose.rscopy_into.rsflush.rsmod.rsread.rsread_exact.rsread_to_end.rsread_until.rsseek.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.rsenumerate.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

and_then.rserr_into.rsinto_async_read.rsinto_stream.rsmap_err.rsmap_ok.rsmod.rsor_else.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

>

//! Futures-powered synchronization primitives.

#[cfg(feature = "std")]
mod mutex;
#[cfg(feature = "std")]
pub use self::mutex::{Mutex, MutexLockFuture, MutexGuard};

mod bilock;
#[cfg(any(test, feature = "bench"))]
pub use self::bilock::{BiLock, BiLockAcquire, BiLockGuard, ReuniteError};
#[cfg(not(any(test, feature = "bench")))]
pub(crate) use self::bilock::BiLock;