diff --git a/grpc.go b/grpc.go index 80e8ed2..bd1b701 100644 --- a/grpc.go +++ b/grpc.go @@ -231,6 +231,14 @@ func (g *grpcClient) stream(ctx context.Context, addr string, req client.Request grpcDialOptions = append(grpcDialOptions, opts...) } + contextDialer := g.opts.ContextDialer + if opts.ContextDialer != nil { + contextDialer = opts.ContextDialer + } + if contextDialer != nil { + grpcDialOptions = append(grpcDialOptions, grpc.WithContextDialer(contextDialer)) + } + cc, err := g.pool.getConn(dialCtx, addr, grpcDialOptions...) if err != nil { return errors.InternalServerError("go.micro.client", fmt.Sprintf("Error sending request: %v", err))