diff --git a/protocol_grpc_client_stream.go b/protocol_grpc_client_stream.go index 21e7501f..ed44c061 100644 --- a/protocol_grpc_client_stream.go +++ b/protocol_grpc_client_stream.go @@ -276,7 +276,7 @@ func (cs *duplexClientStream) makeRequest(prepared chan struct{}) { // establish the receive side of the stream. response, err := cs.httpClient.Do(request) if err != nil { - cs.setResponseError(err) + cs.setResponseError(NewError(CodeUnavailable, err)) return }