How to set a per-call timeout

[ncteisen]

Is it possible to set a per-call timeout using wire gRPC for Kotlin?

I am looking to do something like:

val response = client.SomeRpcMethod().setTimeout(Seconds(5)).executeBlocking(request)

Is this possible? I know I could probably recreate this by using the suspend-able API, but I wondered if there was a more idiomatic way to accomplish this

[oldergod]

You can set the timeout field on the GrpcCall or GrpcStreamingCall object you'll get by calling the rpc method.

• https://square.github.io/wire/3.x/wire-grpc-client/com.squareup.wire/-grpc-call/
• https://square.github.io/wire/3.x/wire-grpc-client/com.squareup.wire/-grpc-streaming-call/

[ncteisen]

timeout is a val field, so it cannot be set. Do you have any code examples of overriding it?

[oldergod]

My response was confusing. The timeout object is mutable. Update it.

[ncteisen]

Ahh thank you I understand now. Just to double confirm (and for any future readers), a code snippet would be:

val grpcCall = someGrpcClient.SomeRpcMethod()
grpcCall.timeout.deadline(2, TimeUnit.SECONDS)
val response = grpcCall.execute(request)

[ezamelczyk]

This just adds a header to the call without actually enforcing the timeout as far as I can tell.