☰

Files

futures

futures_channel

mpsc

mod.rs queue.rs sink_impl.rs

lib.rs lock.rs oneshot.rs

futures_core

future

future_obj.rs mod.rs

stream

task

__internal

atomic_waker.rs mod.rs

mod.rs poll.rs spawn.rs

lib.rs never.rs

futures_executor

enter.rs lib.rs local_pool.rs thread_pool.rs unpark_mutex.rs

futures_io

futures_select_macro

futures_sink

futures_test

future

assert_unmoved.rs mod.rs pending_once.rs

io

read

write

limited.rs mod.rs

stream

task

context.rs mod.rs noop_spawner.rs panic_spawner.rs panic_waker.rs record_spawner.rs wake_counter.rs

assert.rs interleave_pending.rs lib.rs

futures_util

async_await

join.rs mod.rs pending.rs poll.rs select_mod.rs

compat

compat01as03.rs compat03as01.rs executor.rs mod.rs

future

abortable.rs catch_unwind.rs chain.rs either.rs flatten.rs flatten_stream.rs fuse.rs inspect.rs into_stream.rs join.rs join_all.rs lazy.rs map.rs maybe_done.rs mod.rs never_error.rs option.rs pending.rs poll_fn.rs ready.rs remote_handle.rs select.rs select_all.rs shared.rs then.rs unit_error.rs

io

allow_std.rs buf_reader.rs buf_writer.rs close.rs copy_buf_into.rs copy_into.rs flush.rs into_sink.rs lines.rs mod.rs read.rs read_exact.rs read_line.rs read_to_end.rs read_until.rs read_vectored.rs seek.rs split.rs window.rs write.rs write_all.rs write_vectored.rs

lock

bilock.rs mod.rs mutex.rs

sink

buffer.rs close.rs drain.rs err_into.rs fanout.rs flush.rs map_err.rs mod.rs send.rs send_all.rs with.rs with_flat_map.rs

stream

futures_unordered

abort.rs iter.rs mod.rs ready_to_run_queue.rs task.rs

buffer_unordered.rs buffered.rs catch_unwind.rs chain.rs chunks.rs collect.rs concat.rs empty.rs enumerate.rs filter.rs filter_map.rs flatten.rs fold.rs for_each.rs for_each_concurrent.rs forward.rs fuse.rs futures_ordered.rs inspect.rs into_future.rs iter.rs map.rs mod.rs next.rs once.rs peek.rs pending.rs poll_fn.rs repeat.rs select.rs select_all.rs select_next_some.rs skip.rs skip_while.rs split.rs take.rs take_while.rs then.rs unfold.rs zip.rs

task

arc_wake.rs mod.rs noop_waker.rs spawn.rs waker_ref.rs

try_future

and_then.rs err_into.rs flatten_sink.rs flatten_stream_sink.rs inspect_err.rs inspect_ok.rs into_future.rs map_err.rs map_ok.rs mod.rs or_else.rs select_ok.rs try_chain.rs try_flatten_stream.rs try_join.rs try_join_all.rs try_select.rs unwrap_or_else.rs

try_stream

and_then.rs err_into.rs inspect_err.rs inspect_ok.rs into_async_read.rs into_stream.rs map_err.rs map_ok.rs mod.rs or_else.rs try_buffer_unordered.rs try_collect.rs try_concat.rs try_filter.rs try_filter_map.rs try_fold.rs try_for_each.rs try_for_each_concurrent.rs try_next.rs try_skip_while.rs

>

//! Additional combinators for testing async IO.

mod limited;

pub mod read;
pub use read::AsyncReadTestExt;

pub mod write;
pub use write::AsyncWriteTestExt;

Help

Keyboard Shortcuts

?: Show this help dialog
S: Focus the search field
↑: Move up in search results
↓: Move down in search results
↹: Switch tab
⏎: Go to active search result
+: Expand all sections
-: Collapse all sections

Search Tricks

Prefix searches with a type followed by a colon (e.g., fn:) to restrict the search to a given type.

Accepted types are: fn, mod, struct, enum, trait, type, macro, and const.

Search functions by type signature (e.g., vec -> usize or * -> vec)

Search multiple things at once by splitting your query with comma (e.g., str,u8 or String,struct:Vec,test)