Files

drone_core

bitfield

bits.rsmod.rs

ffi

c_str.rsc_string.rslibc.rsmod.rs

fib

chain.rsclosure.rsfuture.rsgenerator.rsmod.rsstream_pulse.rsstream_ring.rs

heap

allocator.rsmod.rspool.rs

io

mod.rsread.rsseek.rswrite.rs

log

macros.rsmod.rsport.rs

reg

field.rsmarker.rsmod.rsprelude.rstag.rs

sync

spsc

oneshot

mod.rsreceiver.rssender.rs

pulse

mod.rsreceiver.rssender.rs

ring

mod.rsreceiver.rssender.rs

mod.rs

linked_list.rsmod.rsmutex.rs

thr

soft

mod.rswake.rs

exec.rsmod.rsprelude.rs

inventory.rslang_items.rslib.rsmem.rsperiph.rsprelude.rsproc_loop.rstoken.rs

drone_cortexm

drv

mod.rssys_tick.rstimer.rs

fib

proc

fiber.rsmod.rsyielder.rs

mod.rs

map

periph

mod.rssys_tick.rs

reg

dwt.rsitm.rsmod.rsscb.rsstk.rstpiu.rs

mod.rsthr.rs

reg

atomic.rsbit_band.rsfield.rsmarker.rsmod.rsprelude.rs

sv

mod.rsswitch.rs

swo

mod.rsport.rs

thr

wake

int.rsmod.rsroot.rs

init.rsint.rsmod.rsnvic.rsprelude.rsroot.rs

lib.rsproc_loop.rsprocessor.rsrt.rs

drone_ctypes

lib.rs

drone_stm32_map

periph

mod.rs

lib.rsreg.rsthr.rs

drone_stm32_map_periph_adc

lib.rs

drone_stm32_map_periph_dma

ch

mod.rs

lib.rs

drone_stm32_map_periph_exti

lib.rs

drone_stm32_map_periph_gpio

head

mod.rs

pin

mod.rs

lib.rs

drone_stm32_map_periph_i2c

lib.rs

drone_stm32_map_periph_rtc

lib.rs

drone_stm32_map_periph_spi

lib.rs

drone_stm32_map_periph_tim

lib.rs

drone_stm32_map_periph_uart

lib.rs

drone_stm32_map_pieces

lib.rs

drone_stm32_map_pieces_1

lib.rs

drone_stm32_map_pieces_10

lib.rs

drone_stm32_map_pieces_11

lib.rs

drone_stm32_map_pieces_12

lib.rs

drone_stm32_map_pieces_2

lib.rs

drone_stm32_map_pieces_3

lib.rs

drone_stm32_map_pieces_4

lib.rs

drone_stm32_map_pieces_5

lib.rs

drone_stm32_map_pieces_6

lib.rs

drone_stm32_map_pieces_7

lib.rs

drone_stm32_map_pieces_8

lib.rs

drone_stm32_map_pieces_9

lib.rs

futures

lib.rs

futures_channel

lib.rslock.rsoneshot.rs

futures_core

task

__internal

atomic_waker.rsmod.rs

mod.rspoll.rs

future.rslib.rsstream.rs

futures_io

lib.rs

futures_sink

lib.rs

futures_task

arc_wake.rsfuture_obj.rslib.rsnoop_waker.rsspawn.rswaker.rswaker_ref.rs

futures_util

async_await

join_mod.rsmod.rspending.rspoll.rsselect_mod.rs

future

future

flatten.rsfuse.rsmap.rsmod.rs

try_future

into_future.rsmod.rstry_flatten.rstry_flatten_err.rs

abortable.rseither.rsjoin.rsjoin_all.rslazy.rsmaybe_done.rsmod.rsoption.rspending.rspoll_fn.rsready.rsselect.rsselect_all.rsselect_ok.rstry_join.rstry_join_all.rstry_maybe_done.rstry_select.rs

lock

bilock.rsmod.rs

sink

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

stream

futures_unordered

abort.rsiter.rsmod.rsready_to_run_queue.rstask.rs

stream

buffer_unordered.rsbuffered.rschain.rschunks.rscollect.rsconcat.rscycle.rsenumerate.rsfilter.rsfilter_map.rsflatten.rsfold.rsfor_each.rsfor_each_concurrent.rsforward.rsfuse.rsinto_future.rsmap.rsmod.rsnext.rspeek.rsready_chunks.rsscan.rsselect_next_some.rsskip.rsskip_while.rssplit.rstake.rstake_until.rstake_while.rsthen.rsunzip.rszip.rs

try_stream

and_then.rsinto_stream.rsmod.rsor_else.rstry_buffer_unordered.rstry_buffered.rstry_collect.rstry_concat.rstry_filter.rstry_filter_map.rstry_flatten.rstry_fold.rstry_for_each.rstry_for_each_concurrent.rstry_next.rstry_skip_while.rstry_take_while.rstry_unfold.rs

empty.rsfutures_ordered.rsiter.rsmod.rsonce.rspending.rspoll_fn.rsrepeat.rsrepeat_with.rsselect.rsselect_all.rsunfold.rs

task

mod.rsspawn.rs

fns.rslib.rsnever.rsunfold_state.rs

pin_project_lite

lib.rs

pin_utils

lib.rsprojection.rsstack_pin.rs

proc_macro_nested

lib.rs

typenum

array.rsbit.rsint.rslib.rsmarker_traits.rsoperator_aliases.rsprivate.rstype_operators.rsuint.rs

>

use core::{future::Future, pin::Pin};

/// The `Read` trait allows for reading bytes from a source asynchronously.
pub trait Read<'sess> {
    /// The error type returned by [`Read::read`].
    type Error;

    /// Pull some bytes from this source into the specified buffer
    /// asynchronously, eventually returning how many bytes were read.
    fn read(
        &'sess mut self,
        buf: &'sess mut [u8],
    ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'sess>>;
}