buzz API

clicks.js

import buzz from '@maxhoffmann/buzz';

function clicks(broadcast) {
  window.addEventListener('click', broadcast('click'));
}
const logger = () => console.log;

const services = [logger, clicks];

buzz(services);

counter.js

import buzz from '@maxhoffmann/buzz';

const logger = () => console.log;

function clicks(broadcast) {
  window.addEventListener('click', broadcast('click'));
}

function counter(broadcast) {
  let state = 0;

  return message => {
    if (message.type === 'click') {
      state += 1;
      broadcast('counter')(state);
    }
  }
}

const services = [logger, clicks, counter];

buzz(services);

view.js

import buzz from '@maxhoffmann/buzz';

function clicks(broadcast) {
  window.addEventListener('click', broadcast('click'));
}

function counter(broadcast) {
  let state = 0;
  return message => {
    if (message.type === 'click') {
      state += 1;
      broadcast('counter')(state);
    }
  }
}

function view() {
  return message => {
    if (message.type === 'counter') {
      document.body.innerHTML = message.data;
    }
  }
}

const services = [clicks, counter, view];

buzz(services);