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)