anchor.diff:      }
     }
     
  -  Future<WorkerPool> initAll() => Future.wait(sockets.map((it) => it.init()).toList()).then((_) => this);
  +  Future<WorkerPool> init() => Future.wait(sockets.map((it) => it.init()).toList()).then((_) => this);
     
     void forEach(void handler(WorkerSocket socket)) {
       sockets.forEach(handler);
  
positive.code: }
  
  main() async {
    var pool = await createWorkerPool(4, testWorker).initAll();
    
    pool.sendAll("Hello World");
    
    await pool.stopAll();
  }
negative.code:   
    WorkerPool(this.sockets);
    
    Future waitFor() {
      return Future.wait(sockets.map((it) => it.waitFor()).toList());
    }
    
    Future stop() {
      return Future.wait(sockets.map((it) => it.stop()).toList());
    }
    
    Future ping() {
      return Future.wait(sockets.map((it) => it.ping()).toList());
    }
    
    void send(dynamic data) {
      forEach((socket) => socket.send(data));
    }
    
    void listen(void handler(int worker, event)) {
      var i = 0;
      for (var worker in sockets) {
        var id = i;
  