diff --git a/common/signal/pubsub/pubsub.go b/common/signal/pubsub/pubsub.go index 16146200f..77b2454a1 100644 --- a/common/signal/pubsub/pubsub.go +++ b/common/signal/pubsub/pubsub.go @@ -87,8 +87,7 @@ func (s *Service) Subscribe(name string) *Subscriber { done: done.New(), } s.Lock() - subs := append(s.subs[name], sub) - s.subs[name] = subs + s.subs[name] = append(s.subs[name], sub) s.Unlock() common.Must(s.ctask.Start()) return sub diff --git a/infra/vformat/main.go b/infra/vformat/main.go index 4bf70537d..323173a29 100644 --- a/infra/vformat/main.go +++ b/infra/vformat/main.go @@ -93,8 +93,8 @@ func Run(binary string, args []string) (string, error) { func RunMany(binary string, args, files []string) { fmt.Println("Processing...") for _, file := range files { - args2 := append(args, file) - output, err := Run(binary, args2) + args := append(args, file) + output, err := Run(binary, args) if err != nil { fmt.Println(err) continue