$_.unneeded(_ => {
}, Infinity)

var subscribers = []

var os = use('os')

$_.receiver(e => {
  console.log(json.encode(e))
  return
  if (e.op === "subscribe") {
    if (!e.actor) throw Error('Got a subscribe message with no actor.');
    subscribers.push(e.actor)
    return;
  }
  
  for (var a of subscribers)
    send(a, e);
});