collectLive with each trigger

Signed-off-by: clemo <clemo@cbcode.at>

lib/ssb-cache/index.js

@@ -106,7 +106,7 @@ export class ssbCache extends Ssb {
   * @param {function} cb - `(err) => {...}`
   * @return {object} liveFeed - `liveFeed.stop();` //will trigger cb
   **/
-  collectLive(cb){
+  collectLive(cb,each){
     // let _on = {'msg':[]}
     let _stop = false;
     this.syncLastNode((err)=> {
@@ -120,7 +120,9 @@ export class ssbCache extends Ssb {
         if(_stop){
           args[1](true); //next(true) = end of stream
         }else{
-          //trigger!
+          if(typeof each === 'undefined'){
+            each(...args);
+          }
           this.addMsg(...args);
         }
       },(err,...args) => {