From c37081ec191dc429cfb7d6ad2ee350474ca6dd84 Mon Sep 17 00:00:00 2001 From: pugnack Date: Wed, 11 Jun 2025 11:37:55 +0500 Subject: [PATCH] add missing outgoing key to ctx for subscribers (#224) --- handler.go | 1 + subscriber.go | 1 + 2 files changed, 2 insertions(+) diff --git a/handler.go b/handler.go index bfe601c..ec86b61 100644 --- 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 diff --git a/subscriber.go b/subscriber.go index 4ddee71..f81fbad 100644 --- 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))