reduceWorkers method

void reduceWorkers(
  1. int count
)

Implementation

void reduceWorkers(int count) async {
  if (sockets.length > count) {
    var toRemove = sockets.length - count;
    var socks = sockets.skip(count).take(toRemove).toList();
    for (var sock in socks) {
      await sock.close();
      sock.kill();
      sockets.remove(sock);
    }
  }
}