diff --git a/pkg/listener/listener.go b/pkg/listener/listener.go index 76e6a7b..5891763 100644 --- a/pkg/listener/listener.go +++ b/pkg/listener/listener.go @@ -351,11 +351,11 @@ func (l *Listener) startMetricsCollector(_ context.Context) error { metricNameLastReceivedBlockNumber, metric.WithInt64Callback(func(_ context.Context, obsrv metric.Int64Observer) error { l.mu.Lock() - lastReceivedBlockNumber := l.lastReceivedBlock.Number + lastReceivedBlock := l.lastReceivedBlock l.mu.Unlock() - if lastReceivedBlockNumber != nil { - obsrv.Observe(lastReceivedBlockNumber.Int64()) + if lastReceivedBlock != nil && lastReceivedBlock.Number != nil { + obsrv.Observe(lastReceivedBlock.Number.Int64()) } return nil