Fixing issue with prefetching ddb page when at the end of stream

lib/stream/leo-stream.js

@@ -1541,7 +1541,7 @@ module.exports = function(configure) {
 				}
 
 				let getEvents;
-
+				let getEventsInit = () => { };
 				if (leoEvent.v >= 2 || !leoEvent.max_eid) {
 					var max_eid = (configure.registry && configure.registry.__cron && configure.registry.__cron.maxeid) || opts.maxOverride || leoEvent.max_eid || ls.eventIdFromTimestamp(Date.now(), "full", 0);
 					var table_name = configure.resources.LeoStream;
@@ -1586,7 +1586,10 @@ module.exports = function(configure) {
 					};
 
 					// Bootstrap the process to query the table
-					let nextGetEventPromise = new Promise((resolve) => getEventsQuery((err, data) => resolve({ err, data })));
+					let nextGetEventPromise;
+					getEventsInit = () => {
+						nextGetEventPromise = new Promise((resolve) => getEventsQuery((err, data) => resolve({ err, data })));
+					};
 
 					getEvents = function(callback) {
 						nextGetEventPromise.then((response) => {
@@ -1627,6 +1630,7 @@ module.exports = function(configure) {
 					eid: start
 				});
 				if (usingSnapshot || max_eid.localeCompare(start) > 0) {
+					getEventsInit();
 					async.whilst(() => {
 						logger.debug("checking next loop, loops remaining ", hasLoops, ", Time Remaining:", opts.stopTime - moment.now());
 						hasTime = hasTime && (opts.stopTime > moment.now());