full OID walk doesn't yield until walk is complete about puresnmp HOT 4 CLOSED

--- C:/Users/royce3/AppData/Local/Temp/TortoiseGit/__init__-fd35dc5.000.py	Sun Feb 11 09:35:47 2018
+++ C:/cvs/puresnmp_remdragon/puresnmp/__init__.py	Sun Feb 11 09:31:39 2018
@@ -188,7 +188,15 @@
     LOG.debug('%d of %d OIDs need to be continued',
               len(unfinished_oids),
               len(oids))
-    output = group_varbinds(varbinds, requested_oids)
+    yielded = _set([])
+    for v in group_varbinds(varbinds, requested_oids).values():
+        #print ( '1: v={!r}'.format ( v ) )
+        for varbind in v:
+            containment = [varbind.oid in _ for _ in requested_oids]
+            if not any(containment) or varbind.oid in yielded:
+                continue
+            yielded.add(varbind.oid)
+            yield varbind
 
     # As long as we have unfinished OIDs, we need to continue the walk for
     # those.
@@ -208,19 +216,15 @@
         LOG.debug('%d of %d OIDs need to be continued',
                   len(unfinished_oids),
                   len(oids))
-        for k, v in group_varbinds(varbinds, next_fetches).items():
-            for ko, vo in output.items():
-                if k in ko:
-                    vo.extend(v)
-
-    yielded = _set([])
-    for v in output.values():
-        for varbind in v:
-            containment = [varbind.oid in _ for _ in requested_oids]
-            if not any(containment) or varbind.oid in yielded:
-                continue
-            yielded.add(varbind.oid)
-            yield varbind
+        for v in group_varbinds(varbinds, next_fetches).values():
+            #print ( '2: v={!r}'.format ( v ) )
+            for varbind in v:
+                containment = [varbind.oid in _ for _ in requested_oids]
+                #print ( '2a: v={!r}, containment={!r}'.format ( v, containment ) )
+                if not any(containment) or varbind.oid in yielded:
+                    continue
+                yielded.add(varbind.oid)
+                yield varbind
 
 
 def set(ip, community, oid, value, port=161, timeout=2):