| 278 | var self = this; |
| 279 | |
| 280 | function getDelta() { |
| 281 | self.delta(cursor, optargs, function(err, data) { |
| 282 | if (err) { return ee.emit('error', err); } |
| 283 | |
| 284 | // only emit changes if cursor was given |
| 285 | if (cursor) { |
| 286 | if (data.reset) { |
| 287 | ee.emit('reset'); |
| 288 | } |
| 289 | |
| 290 | for (var i = 0, len = data.entries.length; i < len; i++) { |
| 291 | var e = data.entries[i]; |
| 292 | ee.emit('data', e[0], e[1]); |
| 293 | } |
| 294 | } |
| 295 | |
| 296 | cursor = data.cursor; |
| 297 | if (data.has_more) { |
| 298 | ee.resume(); |
| 299 | } |
| 300 | }); |
| 301 | } |
| 302 | |
| 303 | ee.resume = function() { |
| 304 | getDelta(); |