fixup! Handle EIO deadlock when H2 returned an error like 404.

tmcgilchrist · tmcgilchrist · commit 3dee73157556 · 2025-11-27T14:24:22.000+11:00
diff --git a/examples/greeter-client-eio/greeter_client_eio.ml b/examples/greeter-client-eio/greeter_client_eio.ml
@@ -40,7 +40,7 @@ let main env =
 
     let result =
       Grpc_eio.Client.call ~service:"mypackage.Greeter" ~rpc:"SayHello"
-        ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+        ~do_request:(H2_eio.Client.request connection)
         ~handler:(Grpc_eio.Client.Rpc.unary encoded_request ~f)
         ()
     in
diff --git a/examples/routeguide-tutorial.md b/examples/routeguide-tutorial.md
@@ -440,7 +440,7 @@ let call_get_feature connection point =
   let encode, decode = Service.make_client_functions RouteGuide.getFeature in
   let response =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"GetFeature"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.unary
            (encode point |> Writer.contents)
@@ -477,7 +477,7 @@ let print_features connection =
   let encode, decode = Service.make_client_functions RouteGuide.listFeatures in
   let stream =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"ListFeatures"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.server_streaming
            (encode rectangle |> Writer.contents)
@@ -529,7 +529,7 @@ let run_record_route connection =
   let encode, decode = Service.make_client_functions RouteGuide.recordRoute in
   let response =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"RecordRoute"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.client_streaming ~f:(fun f response ->
              (* Stream points to server. *)
@@ -616,7 +616,7 @@ We start by generating a short sequence of locations, similar to how we did for
   in
   let result =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"RouteChat"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.bidirectional_streaming ~f:(fun writer reader ->
              go writer reader route_notes))
diff --git a/examples/routeguide/src/client.ml b/examples/routeguide/src/client.ml
@@ -23,7 +23,7 @@ let call_get_feature connection point =
   let encode, decode = Service.make_client_functions RouteGuide.getFeature in
   let response =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"GetFeature"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.unary
            (encode point |> Writer.contents)
@@ -56,7 +56,7 @@ let print_features connection =
   let encode, decode = Service.make_client_functions RouteGuide.listFeatures in
   let stream =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"ListFeatures"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.server_streaming
            (encode rectangle |> Writer.contents)
@@ -101,7 +101,7 @@ let run_record_route connection =
   let encode, decode = Service.make_client_functions RouteGuide.recordRoute in
   let response =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"RecordRoute"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.client_streaming ~f:(fun f response ->
              (* Stream points to server. *)
@@ -179,7 +179,7 @@ let run_route_chat clock connection =
   in
   let result =
     Client.call ~service:"routeguide.RouteGuide" ~rpc:"RouteChat"
-      ~do_request:(H2_eio.Client.request connection ~error_handler:ignore)
+      ~do_request:(H2_eio.Client.request connection)
       ~handler:
         (Client.Rpc.bidirectional_streaming ~f:(fun writer reader ->
              go writer reader route_notes))
