let run_stream_processor ?self_ids t : Make_fun.t = Make_fun.with_requirements t.run_program (Make_fun.stream_processor [] |> Make_fun.with_self_ids ?self_ids)