diff --git a/monitor.go b/monitor.go index 084cfc2..a867896 100644 --- a/monitor.go +++ b/monitor.go @@ -201,7 +201,7 @@ func (m *Monitor) Callback() chan any { }*/ func (m *Monitor) download(ctx context.Context, k string, v uint64) error { - if m.mode != params.LAZY && m.callback != nil { + if m.callback != nil { select { case m.callback <- types.NewBitsFlow(k, v): case <-ctx.Done():