diff --git a/track/base.go b/track/base.go index 31e5271..b9729f6 100644 --- a/track/base.go +++ b/track/base.go @@ -68,6 +68,8 @@ func (bt *Base[T, F]) SnapForJson() { func (bt *Base[T, F]) SetStuff(stuff ...any) { for _, s := range stuff { switch v := s.(type) { + case common.IStream: + bt.Zap = v.With(zap.String("track", bt.Name)) case common.IPuber: bt.Publisher = v bt.Zap = v.With(zap.String("track", bt.Name))