should make active change accessible

Author: pemrouz

dist/index.js

@@ -54,7 +54,10 @@ function data(ripple) {
       res.body = (0, _set2.default)()(res.body || [], existing.body && existing.body.log, _is2.default.num(res.headers.log) ? res.headers.log : -1);
       (0, _overwrite2.default)(res.body.on)(listeners(existing));
       res.body.on('change.bubble', function (change) {
-        return ripple.emit('change', [res.name, change], (0, _not2.default)(_is2.default.in(['data'])));
+        console.log("before", ripple.change);
+        ripple.emit('change', ripple.change = [res.name, change], (0, _not2.default)(_is2.default.in(['data'])));
+        console.log("here", ripple.change);
+        delete ripple.change;
       });
 
       return res;

src/index.js

@@ -17,7 +17,10 @@ export default function data(ripple){
       , is.num(res.headers.log) ? res.headers.log : -1
       )
       overwrite(res.body.on)(listeners(existing))
-      res.body.on('change.bubble', change => ripple.emit('change', [res.name, change], not(is.in(['data']))))
+      res.body.on('change.bubble', change => {
+        ripple.emit('change', ripple.change = [res.name, change], not(is.in(['data'])))
+        delete ripple.change
+      })
 
       return res
     }

test.js

@@ -2,6 +2,7 @@ var core = require('rijs.core').default
   , update = require('utilise/update')
   , clone = require('utilise/clone')
   , expect = require('chai').expect
+  , time = require('utilise/time')
   , keys = require('utilise/keys')
   , data = require('./').default
   , key = require('utilise/key')
@@ -152,4 +153,23 @@ describe('Data Type', function() {
     ripple('foo', { bar: 2 })
     expect(ripple.resources.foo.headers.foo).to.eql({ bar: 5 })
   })
+
+  it('should make active change accessible', function(done){
+    var ripple = data(core())
+      , result
+
+    ripple('foo', { bar: 5 })
+    ripple.on('change', function(data){
+      result = ripple.change
+    })
+      
+    expect(ripple.change).to.be.not.ok
+    update('bar', 15)(ripple('foo'))
+    expect(ripple.change).to.be.not.ok
+
+    time(10, function(){
+      expect(result).to.eql(['foo', { type: 'update', key: 'bar', value: 15, time: 1 }])
+      done()
+    })
+  })
 })