Skip to main content

run_async

Function run_async 

Source
pub async fn run_async<S: AsyncSource, C: Sink, W: Work>(
    source: &mut S,
    sink: &mut C,
    execution: &W,
    field: &'static str,
    at: u64,
) -> Result<(), StreamError<S::Error, C::Error>>
Expand description

Suspends source acquisition while preserving the same sticky callback refusal, admission order and complete-EOF boundary as run. Dropping the future drops the borrowed driver, without producing a partial receipt.