Merge branch 'v4' of https://git.unistack.org/unistack-org/micro-server-grpc into v4
All checks were successful
sync / sync (push) Successful in 14s
All checks were successful
sync / sync (push) Successful in 14s
This commit is contained in:
4
grpc.go
4
grpc.go
@@ -399,7 +399,7 @@ func (g *Server) processRequest(ctx context.Context, stream grpc.ServerStream, s
|
|||||||
// execute the handler
|
// execute the handler
|
||||||
appErr := fn(ctx, r, replyv.Interface())
|
appErr := fn(ctx, r, replyv.Interface())
|
||||||
if md := getResponseMetadata(ctx); len(md) > 0 {
|
if md := getResponseMetadata(ctx); len(md) > 0 {
|
||||||
if err = stream.SendHeader(gmetadata.MD(md)); err != nil {
|
if err = stream.SendHeader(md.AsHTTP2()); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -483,7 +483,7 @@ func (g *Server) processStream(ctx context.Context, stream grpc.ServerStream, se
|
|||||||
|
|
||||||
appErr := fn(ctx, r, ss)
|
appErr := fn(ctx, r, ss)
|
||||||
if md := getResponseMetadata(ctx); len(md) > 0 {
|
if md := getResponseMetadata(ctx); len(md) > 0 {
|
||||||
if err := stream.SendHeader(gmetadata.MD(md)); err != nil {
|
if err := stream.SendHeader(md.AsHTTP2()); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user