Function send_stdin_parameters

src/execution/executor.py:301–328

(
        parameters: List[ParameterModel],
        parameter_values,
        raw_output_stream: ObservableBase,
        process_wrapper)

def send_stdin_parameters(
        parameters: List[ParameterModel],
        parameter_values,
        raw_output_stream: ObservableBase,
        process_wrapper):
    for parameter in parameters:
        if not parameter.pass_as.pass_as_stdin():
            continue

        value = parameter_values.get(parameter.name)
        if value is None:
            continue

        if parameter.no_value:
            if read_bool(value):
                value = 'true'
            else:
                value = 'false'

        if isinstance(value, list):
            value = ','.join(string_utils.values_to_string(value))

        if not parameter.stdin_expected_text:
            process_wrapper.write_to_input(value)
        else:
            raw_output_stream.subscribe(_ExpectedTextListener(
                parameter.stdin_expected_text,
                lambda closed_value=value: process_wrapper.write_to_input(closed_value)))


class _ExpectedTextListener: