diff --git a/grpc.go b/grpc.go
index b76270f..4af9101 100644
--- a/grpc.go
+++ b/grpc.go
@@ -295,6 +295,7 @@ func (g *Server) handler(srv interface{}, stream grpc.ServerStream) error {
 
 	// create new context
 	ctx = metadata.NewIncomingContext(ctx, md)
+	ctx = metadata.NewOutgoingContext(ctx, metadata.New(0))
 
 	stream = &streamWrapper{ctx, stream}