Struct ProcessOutput 

pub struct ProcessOutput {
    pub entity: Entity,
    /* private fields */
}

Fields

entity: Entity

Implementations

impl ProcessOutput

pub fn all(&self) -> &str

The whole output string generated by the program.

Does not include the final terminating newline.

pub fn lines(&self) -> Lines<'_>

An iterator over the lines of the output, as string slices.

Examples found in repository

examples/kill.rs (line 50)

fn update(
    mut process_output_event: MessageReader<ProcessOutput>,
    mut process_completed_event: MessageReader<ProcessCompleted>,
) {
    for process_output in process_output_event.read() {
        for line in process_output.lines() {
            println!("Output Line ({:?}): {line}", process_output.entity);
        }
    }
    if let Some(completed) = process_completed_event.read().last() {
        println!(
            "Command {:?} completed (Success - {})",
            completed.entity,
            completed.exit_status.success()
        );
        // Quit the app
        std::process::exit(0);
    }
}

examples/simple.rs (line 28)

fn update(
    mut process_output_event: MessageReader<ProcessOutput>,
    mut process_completed_event: MessageReader<ProcessCompleted>,
) {
    for process_output in process_output_event.read() {
        for line in process_output.lines() {
            println!("Output Line ({:?}): {line}", process_output.entity);
        }
    }
    if let Some(process_completed) = process_completed_event.read().last() {
        println!(
            "Command {:?} completed (Success - {})",
            process_completed.entity,
            process_completed.exit_status.success()
        );
        // Quit the app
        std::process::exit(0);
    }
}

examples/input.rs (line 32)

fn update(
    mut process_output_event: MessageReader<ProcessOutput>,
    mut process_completed_event: MessageReader<ProcessCompleted>,
    mut active_processes: Query<&mut Process>,
) {
    for process_output in process_output_event.read() {
        for line in process_output.lines() {
            println!("{line}");
        }
    }
    if let Ok(mut process) = active_processes.single_mut() {
        process.println("Bevy").unwrap_or_default();
    }
    if let Some(process_completed) = process_completed_event.read().last() {
        println!(
            "Command {:?} completed (Success - {})",
            process_completed.entity,
            process_completed.exit_status.success()
        );
        // Quit the app
        std::process::exit(0);
    }
}

examples/chain_failure.rs (line 44)

fn update(
    mut process_output_event: MessageReader<ProcessOutput>,
    mut process_completed_event: MessageReader<ProcessCompleted>,
    chain_query: Query<(), With<Chain>>,
) {
    for process_output in process_output_event.read() {
        for line in process_output.lines() {
            println!("Output Line ({:?}): {line}", process_output.entity);
        }
    }

    for process_completed in process_completed_event.read() {
        println!(
            "Command {:?} completed (Success - {})",
            process_completed.entity,
            process_completed.exit_status.success()
        );
    }

    // Check if there are no more Chain components (all chains completed)
    if chain_query.is_empty() {
        println!("Chain commands done. Exiting the app.");
        std::process::exit(0);
    }
}

examples/simple_chain.rs (line 40)

fn update(
    mut process_output_event: MessageReader<ProcessOutput>,
    mut process_completed_event: MessageReader<ProcessCompleted>,
    chain_query: Query<(), With<Chain>>,
) {
    for process_output in process_output_event.read() {
        for line in process_output.lines() {
            println!("Output Line ({:?}): {line}", process_output.entity);
        }
    }

    for process_completed in process_completed_event.read() {
        println!(
            "Command {:?} completed (Success - {})",
            process_completed.entity,
            process_completed.exit_status.success()
        );
    }

    // Check if there are no more Chain components (all chains completed)
    if chain_query.is_empty() {
        println!("All chain commands completed. Exiting the app.");
        std::process::exit(0);
    }
}

examples/chain_retries_delay_cleanup.rs (line 48)

fn update(
    mut process_output_event: MessageReader<ProcessOutput>,
    mut process_completed_event: MessageReader<ProcessCompleted>,
    command_query: Query<(), (With<Chain>, With<Retry>, With<Delay>, With<Cleanup>)>,
) {
    for process_output in process_output_event.read() {
        for line in process_output.lines() {
            println!("Output Line ({:?}): {line}", process_output.entity);
        }
    }

    for process_completed in process_completed_event.read() {
        println!(
            "Command {:?} completed (Success - {})",
            process_completed.entity,
            process_completed.exit_status.success()
        );
    }

    // Check if our entity is done running chain commands
    if command_query.is_empty() {
        println!("All commands completed - cleanup performed. Exiting the app.");
        std::process::exit(0);
    }
}

Additional examples can be found in:

• examples/chain_failure_delay_retries.rs

Trait Implementations

impl Debug for ProcessOutput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Message for ProcessOutput

where Self: Send + Sync + 'static,