Fix broadcast type error

Author: Julow

bin/lwt_log_to_logs/main.ml

@@ -100,11 +100,13 @@ let call_reporter r src level over k msgf =
 let mk_broadcast ~state:_ loggers =
   mk_let_var "broadcast_reporters" loggers @@ fun reporters_var ->
   mk_reporter (fun src level over k msgf ->
-      mk_apply_simple [ "List"; "iter" ]
-        [
-          mk_fun ~arg_name:"r" (fun r -> call_reporter r src level over k msgf);
-          reporters_var;
-        ])
+      let f k r _unit = call_reporter r src level over k msgf in
+      let f =
+        let open Mk_function in
+        mk_function (return f $ arg "k" $ arg "r" $ arg "_unit")
+      in
+      mk_apply_simple [ "List"; "fold_left" ]
+        [ f; k; reporters_var; mk_unit_val ])
 
 let mk_dispatch ~state:_ dispatch_f =
   mk_let_var "dispatch_f" dispatch_f @@ fun dispatch_f ->

test/lwt_log_to_logs/migrate.t/run.t

@@ -474,9 +474,9 @@
            {
              Logs.report =
                (fun src level ~over k msgf ->
-                 List.iter
-                   (fun r -> r.Logs.report src level ~over k msgf)
-                   broadcast_reporters);
+                 List.fold_left
+                   (fun k r _unit -> r.Logs.report src level ~over k msgf)
+                   k broadcast_reporters ());
            });
         Lwt.return ()
     | None ->
@@ -535,8 +535,8 @@
            {
              Logs.report =
                (fun src level ~over k msgf ->
-                 List.iter
-                   (fun r -> r.Logs.report src level ~over k msgf)
-                   broadcast_reporters);
+                 List.fold_left
+                   (fun k r _unit -> r.Logs.report src level ~over k msgf)
+                   k broadcast_reporters ());
            });
         Lwt.return ()