@@ -147,9 +147,9 @@ struct
147147 ;;
148148
149149 let make
150- ?(on_request = on_request_default)
151- ?(on_notification = on_notification_default)
152- ()
150+ ?(on_request = on_request_default)
151+ ?(on_notification = on_notification_default)
152+ ()
153153 =
154154 { h_on_request = on_request; h_on_notification = on_notification }
155155 ;;
@@ -176,9 +176,9 @@ struct
176176 Lazy. force remove;
177177 exn ))
178178 (fun () ->
179- Fiber.Var. set cancel_token cancel (fun () ->
180- Table. replace t.pending req.id cancel;
181- h_on_request.on_request t r))
179+ Fiber.Var. set cancel_token cancel (fun () ->
180+ Table. replace t.pending req.id cancel;
181+ h_on_request.on_request t r))
182182 in
183183 let to_response x =
184184 Jsonrpc.Response. ok req.id (In_request. yojson_of_result r x)
@@ -192,8 +192,8 @@ struct
192192 let f send =
193193 Fiber. finalize
194194 (fun () ->
195- Fiber.Var. set cancel_token cancel (fun () ->
196- k (fun r -> send (to_response r))))
195+ Fiber.Var. set cancel_token cancel (fun () ->
196+ k (fun r -> send (to_response r))))
197197 ~finally: (fun () ->
198198 Lazy. force remove;
199199 Fiber. return () )
@@ -265,12 +265,12 @@ struct
265265 cancel
266266 ~on_cancel: (fun () -> on_cancel jsonrpc_req.id)
267267 (fun () ->
268- let + resp = Session. request (Fdecl. get t.session) jsonrpc_req in
269- match resp.result with
270- | Error { code = RequestCancelled ; _ } -> `Cancelled
271- | Ok _ when Fiber.Cancel. fired cancel -> `Cancelled
272- | Ok s -> `Ok (Out_request. response_of_json req s)
273- | Error e -> raise (Jsonrpc.Response.Error. E e))
268+ let + resp = Session. request (Fdecl. get t.session) jsonrpc_req in
269+ match resp.result with
270+ | Error { code = RequestCancelled ; _ } -> `Cancelled
271+ | Ok _ when Fiber.Cancel. fired cancel -> `Cancelled
272+ | Ok s -> `Ok (Out_request. response_of_json req s)
273+ | Error e -> raise (Jsonrpc.Response.Error. E e))
274274 in
275275 match cancel_status with
276276 | Cancelled () -> `Cancelled
@@ -331,8 +331,8 @@ struct
331331 let start_loop t =
332332 Fiber. fork_and_join_unit
333333 (fun () ->
334- let * () = Session. run (Fdecl. get t.session) in
335- Fiber.Pool. stop t.detached)
334+ let * () = Session. run (Fdecl. get t.session) in
335+ Fiber.Pool. stop t.detached)
336336 (fun () -> Fiber.Pool. run t.detached)
337337 ;;
338338
0 commit comments