Event & Threading model proposal (Usege example)

Java 6 or 7.java

// When using Java 6 or 7
Observable<Vector> positions = 
  server.events.playerMove().map(new Fn<PlayerMoveEvent, Vector>() {
    public Vector call(PlayerMoveEvent event) {
      return event.getPlayer().getPosition();
    }
  })
  .async() // continue on threadpool
  .map(new Fn<Vector, Vector>() {
    public Vector call(Vector vector) {
      return /* do complex slow math */;
    }
  })
  .sync() // continue on main thread
  .on(new Callback<Vector>() {
    public void call(Vector vector) {
      /* apply result on the main thread */;
    }
  });
  

Java 8.java

Observable<Vector> positions = 
  server.events.playerMove().map(event -> event.getPlayer().getPosition())
  .async() // continue on threadpool
  .map(vector-> /* do complex slow math */)
  .sync() // continue on main thread
  .on(vector -> /* apply result on the main thread*/ );