-record(true_generator, {
    subject :: gleam@erlang@process:subject(stream:message(any())),
    pid :: gleam@erlang@process:pid_(),
    handle :: fun((stream:state(any()), stream:message(any())) -> gleam@otp@actor:next(stream:state(any()), stream:message(any()))),
    seed :: fun(() -> any())
}).