Skip to content

Commit

Permalink
Update async version and fix deprecation messages.
Browse files Browse the repository at this point in the history
  • Loading branch information
tmcgilchrist committed Jul 30, 2024
1 parent c7bb94b commit f828845
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 7 deletions.
4 changes: 2 additions & 2 deletions dune-project
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@
(ocaml
(>= 4.11))
(async
(>= v0.16))
(>= v0.17))
(grpc
(= :version))
(h2
Expand Down Expand Up @@ -100,7 +100,7 @@
(network rpc serialisation))
(depends
(async
(>= v0.16.0))
(>= v0.17.0))
cohttp
cohttp-lwt
cohttp-lwt-unix
Expand Down
2 changes: 1 addition & 1 deletion grpc-async.opam
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ bug-reports: "https://github.com/dialohq/ocaml-grpc/issues"
depends: [
"dune" {>= "3.7"}
"ocaml" {>= "4.11"}
"async" {>= "v0.16"}
"async" {>= "v0.17"}
"grpc" {= version}
"h2" {>= "0.9.0"}
"ppx_jane" {>= "v0.16.0"}
Expand Down
2 changes: 1 addition & 1 deletion grpc-examples.opam
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ doc: "https://dialohq.github.io/ocaml-grpc"
bug-reports: "https://github.com/dialohq/ocaml-grpc/issues"
depends: [
"dune" {>= "3.7"}
"async" {>= "v0.16.0"}
"async" {>= "v0.17.0"}
"cohttp"
"cohttp-lwt"
"cohttp-lwt-unix"
Expand Down
6 changes: 3 additions & 3 deletions lib/grpc-async/client.ml
Original file line number Diff line number Diff line change
Expand Up @@ -21,12 +21,12 @@ let default_headers =
[ ("te", "trailers"); ("content-type", "application/grpc+proto") ]

let trailers_handler trailers_status_ivar headers =
Ivar.fill trailers_status_ivar (Grpc.Status.extract_status headers)
Async.Ivar.fill_exn trailers_status_ivar (Grpc.Status.extract_status headers)

let response_handler read_body_ivar out_ivar (response : H2.Response.t)
(body : H2.Body.Reader.t) =
Ivar.fill read_body_ivar body;
Ivar.fill out_ivar response
Async.Ivar.fill_exn read_body_ivar body;
Async.Ivar.fill_exn out_ivar response

let call ~service ~rpc ?(scheme = "https") ~handler ~do_request
?(headers = default_headers) () =
Expand Down

0 comments on commit f828845

Please sign in to comment.