feat: make table.Watch() func blocking

This commit is contained in:
wpetit 2021-09-21 11:19:20 +02:00
parent 1cc263ca8b
commit 34fa420040
1 changed files with 6 additions and 5 deletions

View File

@ -55,17 +55,18 @@ func (t *Table) Watch(ctx context.Context, config WatchConfig) error {
return errors.WithStack(err)
}
go func() {
if err := h.ListenAndServe(ctx); err != nil {
panic(errors.WithStack(err))
}
}()
ctx, cancel := context.WithCancel(ctx)
defer cancel()
notifications := make(chan arp.MACEntry)
h.AddNotificationChannel(notifications)
go t.handleNotifications(ctx, notifications)
if err := h.ListenAndServe(ctx); err != nil {
return errors.WithStack(err)
}
return nil
}