From afac9f1eb90c5ba2f95a593b93e74a36086b7dc9 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Fri, 6 Mar 2026 09:04:50 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20poll=20task=20?=
 =?UTF-8?q?=E4=B8=AD=20results=20=E5=92=8C=20poll=5Fpoints=20=E5=8F=AF?=
 =?UTF-8?q?=E8=83=BD=E9=94=99=E4=BD=8D=E7=9A=84=20bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/connection.rs | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/src/connection.rs b/src/connection.rs
index 6f2b34f..aea8441 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -403,12 +403,7 @@ impl ConnectionManager {
                 // 执行批量读取
                 match session.read(&read_requests, TimestampsToReturn::Both, 0f64).await {
                     Ok(results) => {
-                        for (i, result) in results.iter().enumerate() {
-                            if i >= poll_points.len() {
-                                break;
-                            }
-
-                            let poll_point = &poll_points[i];
+                        for (poll_point, result) in poll_points.iter().zip(results.iter()) {
                             let dv = result;
                             let val = dv.value.clone();
                             let unified_value = val.as_ref().map(crate::telemetry::opcua_variant_to_data);