add "idle-proxy" and "once-idle" helpers, add idle option to most types

Author: mmckegg

animation-frame-proxy.js

@@ -19,9 +19,8 @@ function Array (defaultValues, opts) {
   var binder = LazyWatcher(update, listen, unlisten)
   binder.value = object
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.idle) binder.idle = true
+  if (opts && opts.nextTick) binder.nextTick = true
 
   if (defaultValues && defaultValues.length) {
     forEach(defaultValues, add)

array.js

@@ -8,6 +8,7 @@
 var resolve = require('./resolve')
 var isObservable = require('./is-observable')
 var isSame = require('./lib/is-same')
+var onceIdle = require('./once-idle')
 
 module.exports = computed
 
@@ -151,7 +152,12 @@ ProtoComputed.prototype = {
     return false
   },
   onUpdate: function () {
-    if (this.opts && this.opts.nextTick) {
+    if (this.opts && this.opts.idle) {
+      if (!this.updating) {
+        this.updating = true
+        onceIdle(this.boundUpdateNow)
+      }
+    } else if (this.opts && this.opts.nextTick) {
       if (!this.updating) {
         this.updating = true
         setImmediate(this.boundUpdateNow)

computed.js

@@ -19,9 +19,8 @@ function Dict (defaultValues, opts) {
   var binder = LazyWatcher(update, listen, unlisten)
   binder.value = object
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.nextTick) binder.nextTick = true
+  if (opts && opts.idle) binder.idle = true
 
   if (defaultValues) {
     forEachPair(defaultValues, put)

dict.js

@@ -0,0 +1,8 @@
+var Proxy = require('./proxy')
+var onceIdle = require('./once-idle')
+
+module.exports = function IdleProxy (fn) {
+  var obs = Proxy()
+  onceIdle(() => obs.set(fn()))
+  return obs
+}

idle-proxy.js

@@ -1,3 +1,5 @@
+var onceIdle = require('../once-idle')
+
 module.exports = function (update, onBind, onUnbind) {
   var lazy = false
   var context = this
@@ -6,6 +8,7 @@ module.exports = function (update, onBind, onUnbind) {
   var obj = {
     live: false,
     nextTick: false,
+    idle: false,
     suspended: false,
     update: update,
     value: null,
@@ -31,7 +34,12 @@ module.exports = function (update, onBind, onUnbind) {
     },
 
     onUpdate: function () {
-      if (obj.nextTick) {
+      if (obj.idle) {
+        if (!updating) {
+          updating = true
+          onceIdle(obj.updateAndBroadcast)
+        }
+      } else if (obj.nextTick) {
         if (!updating) {
           updating = true
           setImmediate(obj.updateAndBroadcast)

lib/lazy-watcher.js

@@ -2,6 +2,7 @@ var resolve = require('./resolve')
 var LazyWatcher = require('./lib/lazy-watcher')
 var isSame = require('./lib/is-same')
 var addCollectionMethods = require('./lib/add-collection-methods')
+var onceIdle = require('./once-idle')
 
 module.exports = Map
 
@@ -12,9 +13,8 @@ function Map (obs, lambda, opts) {
   var releases = []
   var binder = LazyWatcher(update, listen, unlisten)
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.nextTick) binder.nextTick = true
+  if (opts && opts.idle) binder.idle = true
 
   var itemInvalidators = new global.Map()
   var lastValues = new global.Map()
@@ -263,7 +263,9 @@ function Map (obs, lambda, opts) {
   }
 
   function doSoon (fn) {
-    if (opts.delayTime) {
+    if (opts.idle) {
+      onceIdle(fn)
+    } else if (opts.delayTime) {
       setTimeout(fn, opts.delayTime)
     } else {
       setImmediate(fn)

map.js

@@ -1,6 +1,6 @@
 var queue = []
 var running = false
-var max = 1 / 60 / 2
+var max = 1000 / 60
 
 module.exports = function (fn) {
   if (typeof fn !== 'function') {
@@ -9,7 +9,7 @@ module.exports = function (fn) {
   queue.push(fn)
   if (!running) {
     running = true
-    window.requestAnimationFrame(flush)
+    window.requestIdleCallback(flush)
   }
 }
 
@@ -21,7 +21,7 @@ function flush () {
   }
 
   if (queue.length) {
-    window.requestAnimationFrame(flush)
+    window.requestIdleCallback(flush)
   } else {
     running = false
   }

animation-frame.js once-idle.js

@@ -10,9 +10,8 @@ function ProxyCollection (source, opts) {
   var binder = LazyWatcher(update, listen, unlisten)
   binder.value = resolve(source)
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.nextTick) binder.nextTick = true
+  if (opts && opts.idle) binder.idle = true
 
   var observable = function MutantProxyCollection (listener) {
     if (!listener) {

proxy-collection.js

@@ -10,9 +10,8 @@ function ProxyDict (source, opts) {
   var binder = LazyWatcher(update, listen, unlisten)
   binder.value = resolve(source)
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.nextTick) binder.nextTick = true
+  if (opts && opts.idle) binder.idle = true
 
   var observable = function MutantProxyDict (listener) {
     if (!listener) {

proxy-dict.js

@@ -10,9 +10,8 @@ function Proxy (source, opts) {
   var binder = LazyWatcher(update, listen, unlisten)
   binder.value = resolve(source)
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.nextTick) binder.nextTick = true
+  if (opts && opts.idle) binder.idle = true
 
   var observable = function MutantProxy (listener) {
     if (!listener) {

proxy.js

@@ -24,9 +24,8 @@ function ProtoSet (defaultValues, opts) {
   self.binder = LazyWatcher.call(self, self._update, self._listen, self._unlisten)
   self.binder.value = this.object
 
-  if (opts && opts.nextTick) {
-    self.binder.nextTick = true
-  }
+  if (opts && opts.nextTick) self.binder.nextTick = true
+  if (opts && opts.idle) self.binder.idle = true
 
   if (defaultValues && defaultValues.length) {
     defaultValues.forEach(function (valueOrObs) {

set.js

@@ -16,9 +16,8 @@ function Struct (properties, opts) {
   var binder = LazyWatcher(update, listen, unlisten)
   binder.value = object
 
-  if (opts && opts.nextTick) {
-    binder.nextTick = true
-  }
+  if (opts && opts.nextTick) binder.nextTick = true
+  if (opts && opts.idle) binder.idle = true
 
   var comparer = opts && opts.comparer || null
 

struct.js

@@ -1,5 +1,6 @@
 var resolve = require('./resolve')
 var isObservable = require('./is-observable')
+var onceIdle = require('./once-idle')
 
 module.exports = watchAll
 
@@ -19,7 +20,12 @@ function watchAll (observables, listener, opts) {
   }
 
   function broadcast () {
-    if (opts && opts.nextTick) {
+    if (opts && opts.idle) {
+      if (!broadcasting) {
+        broadcasting = true
+        onceIdle(broadcastNow)
+      }
+    } else if (opts && opts.nextTick) {
       if (!broadcasting) {
         broadcasting = true
         setImmediate(broadcastNow)