Struct AsyncCopyStreams 

pub struct AsyncCopyStreams { /* private fields */ }

Async copy scheduler keyed by IR stream tags.

Implementations

impl AsyncCopyStreams

pub fn new() -> Self

Create an empty stream scheduler.

pub fn async_load<F>( &mut self, tag: impl Into<String>, copy: F, ) -> Result<(), BackendError>

where F: FnOnce() -> Result<(), BackendError> + Send + 'static,

Start copy work associated with tag.

If a tokio runtime handle is available on the current thread the closure is dispatched to tokio::task::spawn_blocking so the runtime’s blocking-thread pool amortizes scheduling cost. Otherwise the crate-global bounded async-copy pool is used.

Errors

Returns a backend error if the tag is already in flight.

pub fn async_wait(&mut self, tag: &str) -> Result<(), BackendError>

Wait for a copy previously started by Self::async_load.

Errors

Returns a backend error if the tag is unknown, the worker panicked, or the copy closure returned an error.

pub fn overlap_copy_compute<C, G>( &mut self, tag: impl Into<String>, copy: C, compute: G, ) -> Result<(), BackendError>

where C: FnOnce() -> Result<(), BackendError> + Send + 'static, G: FnOnce() -> Result<(), BackendError>,

Start copy work, run compute work, then wait for the copy tag.

Errors

Propagates copy or compute failures with their original context.

Trait Implementations

impl Default for AsyncCopyStreams

fn default() -> AsyncCopyStreams

Returns the “default value” for a type.

impl Drop for AsyncCopyStreams

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.