From 6de6f4ba0235c0c61ee56fab4b8832515179d21c Mon Sep 17 00:00:00 2001 From: ucwong Date: Sun, 31 Dec 2023 21:52:01 +0800 Subject: [PATCH] lazy fix --- monitor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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():