@@ -462,23 +462,25 @@ let fold ~map ~reduce seq =
462462 | Some other -> Lwd. pure (Some (pure_map_reduce map reduce other))
463463 | None ->
464464 let reducer = ref (Reducer. make ~map ~reduce ) in
465- Lwd. map' seq @@ fun seq ->
466- let reducer' = Reducer. update ! reducer seq in
467- reducer := reducer';
468- Reducer. reduce reducer'
465+ Lwd. map seq ~f: begin fun seq ->
466+ let reducer' = Reducer. update ! reducer seq in
467+ reducer := reducer';
468+ Reducer. reduce reducer'
469+ end
469470
470471let fold_monoid map (zero , reduce ) seq =
471472 match Lwd. is_pure seq with
472473 | Some Nil -> Lwd. pure zero
473474 | Some other -> Lwd. pure (pure_map_reduce map reduce other)
474475 | None ->
475476 let reducer = ref (Reducer. make ~map ~reduce ) in
476- Lwd. map' seq @@ fun seq ->
477- let reducer' = Reducer. update ! reducer seq in
478- reducer := reducer';
479- match Reducer. reduce reducer' with
480- | None -> zero
481- | Some x -> x
477+ Lwd. map seq ~f: begin fun seq ->
478+ let reducer' = Reducer. update ! reducer seq in
479+ reducer := reducer';
480+ match Reducer. reduce reducer' with
481+ | None -> zero
482+ | Some x -> x
483+ end
482484
483485let monoid = (empty, concat)
484486
@@ -535,7 +537,7 @@ let to_array x =
535537
536538let lwd_empty : 'a t Lwd.t = Lwd. pure Nil
537539let lwd_monoid : 'a. 'a t Lwd.t Lwd_utils.monoid =
538- (lwd_empty, fun x y -> Lwd. map2 concat x y)
540+ (lwd_empty, fun x y -> Lwd. map2 ~f: concat x y)
539541
540542let map f seq =
541543 fold_monoid (fun x -> element (f x)) monoid seq
@@ -557,4 +559,4 @@ let seq_bind (seq : 'a seq Lwd.t) (f : 'a -> 'b seq) : 'b seq Lwd.t =
557559 fold_monoid f monoid seq
558560
559561let lift (seq : 'a Lwd.t seq Lwd.t ) : 'a seq Lwd.t =
560- bind seq (Lwd. map element)
562+ bind seq (Lwd. map ~f: element)
0 commit comments