From e956a871075b0b1d496590c496f5dc32440fe278 Mon Sep 17 00:00:00 2001 From: aaron Date: Mon, 8 Dec 2014 04:07:12 -0800 Subject: [PATCH] Tests - Guard against excessive t.end --- test/map-reduce.js | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/test/map-reduce.js b/test/map-reduce.js index bdba4f7..3d247ae 100644 --- a/test/map-reduce.js +++ b/test/map-reduce.js @@ -2,7 +2,6 @@ var level = require('level-test')() var Model = require('scuttlebutt/model') var assert = require('assert') -var rimraf = require('rimraf') var MapReduce = require('map-reduce') var Scuttlebutt = require('..') var SubLevel = require('level-sublevel') @@ -17,7 +16,7 @@ require('tape')('scuttlebutt: map-reduce', function (t) { } }) - var mapDb = + var mapDb = MapReduce(db, 'test', function (key, model, emit) { model = JSON.parse(model) @@ -42,12 +41,12 @@ require('tape')('scuttlebutt: map-reduce', function (t) { t.dispose() } }, 200) - + }, 1000) }) }) - var sq, cu + var sq, cu, hasEnded mapDb.on('reduce', function (group, sum) { console.log('reduce->', group, sum) @@ -65,7 +64,9 @@ require('tape')('scuttlebutt: map-reduce', function (t) { t.ok(true, "eventually ['cube']: 800") } catch (_) { } - if(sq && cu) + if(sq && cu && !hasEnded) { + hasEnded = true t.end() + } }) })