检索GRPC-GO中拦截器中的响应元数据

Question

简而言之：
如何使用grpc.withStreamInterceptor检索响应的初始_metadata，而无需包装grpc.ClientStream？

情况是我尝试使用拦截器来管理所有调用的请求和响应中的元数据。例如，附加密码/令牌以从响应中请求和检索令牌。

首先，我创建一个结构并定义了流互感面

type ClientInterceptor struct {
    Header         string
    Value          string
    ResponseHeader string
    ResponseValue  string
}

func (client *ClientInterceptor) streamInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
    log.Println("Add header in interceptor")
    ctx = metadata.AppendToOutgoingContext(ctx, client.Header, client.Value)
    clientStream, err := streamer(ctx, desc, cc, method, opts...)
    if err != nil {
        return nil, err
    }
    log.Println("Access response header")
    responseMeta, err := s.Header() // Block at here, server not trigger any function
    if err != nil {
        return nil, err
    }
    if val, ok := responseMeta[client.ResponseHeader]; ok {
        client.ResponseValue = val[0]
        log.Println("Response header: ", val[0])
    } else {
        return nil, status.Errorf(codes.DataLoss, "Response without header founded")
    }
    return clientStream, nil
}

，在下面是我的使用方式。

interceptor := &ClientInterceptor{Header: "x-custom", Value: "hello header", ResponseHeader: "x-custom-echo"}
conn, err := grpc.Dial("127.0.0.1:60661", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithStreamInterceptor(interceptor.streamInterceptor))

但是，该代码始终是explsentemeta，err：= s.header（）的代码，并且服务器不显示任何请求。
如果我删除代码的一部分并使用struct包装clienttream，我可以从recvmsg（）获得响应元数据，

type wrappedStream struct {
    grpc.ClientStream
    getHeader bool
}

func (w *wrappedStream) RecvMsg(m interface{}) error {
    if !w.getHeader {
        responseMeta, err := w.Header()
        if err != nil {
            return nil
        }
        if val, ok := responseMeta["x-custom-echo"]; ok {
            log.Println("Response header: ", val[0])
        }
    }
    return w.ClientStream.RecvMsg(m)
}

func (w *wrappedStream) SendMsg(m interface{}) error {
    return w.ClientStream.SendMsg(m)
}

这意味着每个调用都会创建其自己的实例和靠自己存放令牌，这不是我想要的。
我知道我可以使用指针共享值，但似乎有点“脏”。
根据 grpc官方文档先发送没有身体（Protobuf）。
我如何强制将元数据发送到Interceptor中，因为当请求标头到达时，服务器将首先响应元数据（请求主体不必要）。

要重现这种情况，我将其写在