Function mz_compute::sink::copy_to_s3_oneshot::copy_to

fn copy_to<G>(
    sinked_collection: Collection<G, Row, Diff>,
    err_collection: Collection<G, DataflowError, Diff>,
    sink_id: GlobalId,
    up_to: Antichain<G::Timestamp>,
    response_protocol_handle: Rc<RefCell<Option<ResponseProtocol>>>
)where
    G: Scope<Timestamp = Timestamp>,