Mirroristas/gun
2
0
Fork 0
mirror of https://github.com/amark/gun.git synced 2025-11-24 06:25:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

does this work? Check for typo errors... I didn't test.

Browse Source
This commit is contained in:
Mark Nadal 2021-11-11 15:11:58 -08:00 committed by GitHub
parent 74d2b077cd
commit 7e068ef2b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/rs3.js
View File

@ -87,15 +87,16 @@ function Store(opt){
if(err){ return Gun.log(err, err.stack) } if(err){ return Gun.log(err, err.stack) }
var IT = data.IsTruncated, cbe = function(cb){ var IT = data.IsTruncated, cbe = function(cb){
if(cb.end){ return } if(cb.end){ return }
if(Gun.obj.map(data.Contents, function(content){ var i = 0, c = data.Contents, tmp; while(tmp = c[i++]){
return cb(content.Key); if(cb(tmp.Key)){ cb.end = true; break }
})){ cb.end = true; return } }
if(cb.end){ return }
if(IT){ return } if(IT){ return }
// Stream interface requires a final call to know when to be done. // Stream interface requires a final call to know when to be done.
cb.end = true; cb(); cb.end = true; cb();
} }
Gun.obj.map(cbs, cbe); cbs.forEach(cbe);//Gun.obj.map(cbs, cbe);
if(!IT){ Gun.obj.del(c.l, 1); return } if(!IT){ delete c.l[1]; return }
params.ContinuationToken = data.NextContinuationToken; params.ContinuationToken = data.NextContinuationToken;
store.list(cb, match, params, cbs); store.list(cb, match, params, cbs);
}); });