All files / Nodejs/test readTest.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
var leo = require("../index.js");
var moment = require("moment");
 
describe("local", function() {
	it("Should be retrieve a nicely formatted workflow", function(done) {
		this.timeout(60000);
		let count = 0;
		leo.offload({
			id: "ckzSDK_offload",
			queue: "V2FirehoseQueue",
			// batch: {
			// 	size: 2,
			// 	map: (payload, meta, done) => {
			// 		//console.log("My Batch Map", payload)
			// 		done(null, payload);
			// 	}
			// }, // object or number 
			each: (payload, meta, done) => {
				count++;
				console.log(count);
				done(null, true);
			},
			debug: true
		}, (err) => {
			console.log("All Done processing events", err);
			done();
		});
	});
});