in grpc/client/mdforward/mdforward.go [14:31]
func UnaryClientInterceptor() grpc.UnaryClientInterceptor {
return func(
ctx context.Context,
method string,
req, reply any,
cc *grpc.ClientConn,
invoker grpc.UnaryInvoker,
callOpts ...grpc.CallOption,
) error {
md, ok := metadata.FromIncomingContext(ctx)
if ok {
if _, ok := metadata.FromOutgoingContext(ctx); !ok {
ctx = metadata.NewOutgoingContext(ctx, md)
}
}
return invoker(ctx, method, req, reply, cc, callOpts...)
}
}