diff --git a/transport/grpc/client.go b/transport/grpc/client.go index 535b70f..28c203f 100644 --- a/transport/grpc/client.go +++ b/transport/grpc/client.go @@ -91,7 +91,7 @@ for _, f := range c.before { ctx = f(ctx, md) } - ctx = metadata.NewContext(ctx, *md) + ctx = metadata.NewOutgoingContext(ctx, *md) var header, trailer metadata.MD grpcReply := reflect.New(c.grpcReply).Interface() diff --git a/transport/grpc/server.go b/transport/grpc/server.go index b14d7d8..6da4bdb 100644 --- a/transport/grpc/server.go +++ b/transport/grpc/server.go @@ -73,7 +73,7 @@ // ServeGRPC implements the Handler interface. func (s Server) ServeGRPC(ctx oldcontext.Context, req interface{}) (oldcontext.Context, interface{}, error) { // Retrieve gRPC metadata. - md, ok := metadata.FromContext(ctx) + md, ok := metadata.FromIncomingContext(ctx) if !ok { md = metadata.MD{} }