@@ -137,11 +137,11 @@ struct
137
137
;;
138
138
139
139
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
145
145
=
146
146
let pending = Id.Table. create 10 in
147
147
{ chan
@@ -274,8 +274,8 @@ struct
274
274
let * () =
275
275
Fiber. fork_and_join_unit
276
276
(fun () ->
277
- let * () = loop () in
278
- Fiber.Pool. stop later)
277
+ let * () = loop () in
278
+ Fiber.Pool. stop later)
279
279
(fun () -> Fiber.Pool. run later)
280
280
in
281
281
close t)
@@ -358,11 +358,10 @@ struct
358
358
let pending = ! batch in
359
359
batch := [] ;
360
360
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)
366
365
in
367
366
List. iter ivars ~f: (fun (id , ivar ) -> register_request_ivar t id ivar);
368
367
Chan. send t.chan pending)
0 commit comments