observable.js

module.exports = value => {
  const listeners = new Set();
  const etter = (...args) => {
    switch(args.length) {
      case 0: return value;
      case 1: {
        value = args[0];
        listeners.forEach(listener => listener(value));
      }
    }
  };
  
  etter.listeners = listeners;  
  etter.subscribe = listener => {
    listeners.add(listener);
    return etter;
  };
  
  etter.unsubscribe = listener => {
    if(listener) {
      listeners.delete(listener);
    } else {
      listeners.clear();
    }
    return etter;
  };
  
  return etter;
}