Function execute_graph

src/executor.rs:71–89

Entry point for the execution engine. This function consumes the graph (conceptually) and drives the I/O writing process. It returns the `ChildRef` of the Root Chunk, which is needed to write the Global Header. # Type Parameters `W`: The writer type. Must implement `std::io::Write` and `Send`.

(
    graph: &TaskGraph<'a>,
    writer: &SeqWriter<W>,
    registry: &CompressorRegistry,
    use_compression: bool,
)

///
/// * `W`: The writer type. Must implement `std::io::Write` and `Send`.
pub fn execute_graph<'a, W>(
    graph: &TaskGraph<'a>,
    writer: &SeqWriter<W>,
    registry: &CompressorRegistry,
    use_compression: bool,
) -> Result<ChildRef>
where
    W: Write + Send,
{
    #[cfg(all(feature = "parallel", not(target_arch = "wasm32")))]
    {
        execute_graph_parallel(graph, writer, registry, use_compression)
    }

    #[cfg(any(not(feature = "parallel"), target_arch = "wasm32"))]
    {
        execute_graph_serial(graph, writer, registry, use_compression)
    }
}
// ------------

/// Executes the graph in parallel using Rayon.