Skip to main content

run_writer

operator::statement::export_logical_tables::writers

Function run_writer 

Source 
async fn run_writer(
    writer: ActiveWriter,
    receiver: Receiver<Payload>,
    token: &CancellationToken,
) -> Result<()>