/background/storage.js - Diff - Haketilo - Hydrilla issue tracker

« Previous | Next »

Revision d42dadca

Added by koszko about 2 years ago

ID d42dadca04bd2c40cfe836b3f2bbe0ffbf176eda
Parent c483ae19
Child 64afd5b9

extract observables implementation from storage.js

      * IMPORT make_once
      * IMPORT browser
      * IMPORT is_chrome
      * IMPORT observables
      * IMPORTS_END
      */
-...
         for (let item of await get_list_var(name))
     	map.set(item, await get(prefix + item));
         return {map, prefix, name, listeners : new Set(), lock : make_lock()};
         return {map, prefix, name, observable: observables.make(),
     	    lock: make_lock()};
+    }
     var list_by_prefix = {};
-...
     	prefixes = [prefixes];
         for (let prefix of prefixes)
     	list_by_prefix[prefix].listeners.add(cb);
     	observables.subscribe(list_by_prefix[prefix].observable, cb);
+    }
     exports.remove_change_listener = function (cb, prefixes=list_prefixes)
-...
     	prefixes = [prefixes];
         for (let prefix of prefixes)
     	list_by_prefix[prefix].listeners.delete(cb);
+    }
     function broadcast_change(change, list)
+    {
         for (let listener_callback of list.listeners)
     	listener_callback(change);
     	observables.unsubscribe(list_by_prefix[prefix].observable, cb);
+    }
     /* Prepare some hepler functions to get elements of a list */
-...
     	new_val : value
         };
         broadcast_change(change, list);
         observables.broadcast(list.observable, change);
         return old_val;
+    }
-...
     	new_val : undefined
         };
         broadcast_change(change, list);
         observables.broadcast(list.observable, change);
         return old_val;
+    }
-...
     	new_val : undefined
         };
         broadcast_change(change, list);
         observables.broadcast(list.observable, change);
         list.map.set(new_item, new_val);
-...
         change.old_val = undefined;
         change.new_val = new_val;
         broadcast_change(change, list);
         observables.broadcast(list.observable, change);
         return old_val;
+    }
-...
     	for (let [item, val] of list_entries_it(list)) {
     	    change.item = item;
     	    change.old_val = val;
     	    broadcast_change(change, list);
     	    observables.broadcast(list.observable, change);
+    	}
     	list.map = new Map();

Also available in: Unified diff