Function subprocess_pickle_echo

tests/testutils.py:83–94

Echo function with a child Python process Pickle the input data into a buffer, send it to a subprocess via stdin, expect the subprocess to unpickle, re-pickle that data back and send it back to the parent process via stdout for final unpickling. >>> subprocess_pickle_echo([1, 'a', No

(input_data, protocol=None, timeout=TIMEOUT, add_env=None)

def subprocess_pickle_echo(input_data, protocol=None, timeout=TIMEOUT, add_env=None):
    """Echo function with a child Python process
    Pickle the input data into a buffer, send it to a subprocess via
    stdin, expect the subprocess to unpickle, re-pickle that data back
    and send it back to the parent process via stdout for final unpickling.
    >>> subprocess_pickle_echo([1, 'a', None])
    [1, 'a', None]
    """
    out = subprocess_pickle_string(
        input_data, protocol=protocol, timeout=timeout, add_env=add_env
    )
    return loads(out)


def _read_all_bytes(stream_in, chunk_size=4096):