fix: avoid using globals for record counting during concurrent declarative stream reads

fix: avoid using globals for record counting during concurrent declarative stream reads #1438