@@ -137,11 +137,11 @@ struct
137137 ;;
138138
139139 let create
140- ?(on_request = on_request_fail)
141- ?(on_notification = on_notification_fail)
142- ~name
143- chan
144- state
140+ ?(on_request = on_request_fail)
141+ ?(on_notification = on_notification_fail)
142+ ~name
143+ chan
144+ state
145145 =
146146 let pending = Id.Table. create 10 in
147147 { chan
@@ -274,8 +274,8 @@ struct
274274 let * () =
275275 Fiber. fork_and_join_unit
276276 (fun () ->
277- let * () = loop () in
278- Fiber.Pool. stop later)
277+ let * () = loop () in
278+ Fiber.Pool. stop later)
279279 (fun () -> Fiber.Pool. run later)
280280 in
281281 close t)
@@ -358,11 +358,10 @@ struct
358358 let pending = ! batch in
359359 batch := [] ;
360360 let pending, ivars =
361- List. fold_left pending ~init: ([] , [] ) ~f: (fun (pending , ivars ) ->
362- function
363- | `Notification n -> Jsonrpc.Packet. Notification n :: pending, ivars
364- | `Request ((r : Request.t ), ivar ) ->
365- Jsonrpc.Packet. Request r :: pending, (r.id, ivar) :: ivars)
361+ List. fold_left pending ~init: ([] , [] ) ~f: (fun (pending , ivars ) -> function
362+ | `Notification n -> Jsonrpc.Packet. Notification n :: pending, ivars
363+ | `Request ((r : Request.t ), ivar ) ->
364+ Jsonrpc.Packet. Request r :: pending, (r.id, ivar) :: ivars)
366365 in
367366 List. iter ivars ~f: (fun (id , ivar ) -> register_request_ivar t id ivar);
368367 Chan. send t.chan pending)
0 commit comments