add missing outgoing key to ctx for subscribers (#224)

2025-06-11 11:37:55 +05:00
parent 3ab7c5cc29
commit c37081ec19
2 changed files with 2 additions and 0 deletions
--- a/handler.go
+++ b/handler.go
@@ -127,6 +127,7 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		}

 		ctx = metadata.NewIncomingContext(ctx, md)
+		ctx = metadata.NewOutgoingContext(ctx, metadata.New(0))

 		path := r.URL.Path

--- a/subscriber.go
+++ b/subscriber.go
@@ -88,6 +88,7 @@ func (s *Server) createSubHandler(sb *httpSubscriber, opts server.Options) broke

 		hdr := metadata.Copy(msg.Header)
 		ctx := metadata.NewIncomingContext(context.Background(), hdr)
+		ctx = metadata.NewOutgoingContext(ctx, metadata.New(0))

 		results := make(chan error, len(sb.handlers))