public PriorityQueue read()

in chill-java/src/main/java/com/twitter/chill/java/PriorityQueueSerializer.java [65:82]

• 17 lines of code
• 3 McCabe index (conditional complexity)

  public PriorityQueue<?> read(Kryo k, Input i, Class<PriorityQueue<?>> c) {
    Comparator<Object> comp = (Comparator<Object>)k.readClassAndObject(i);
    int sz = i.readInt(true);
    // can't create with size 0:
    PriorityQueue<Object> result;
    if (sz == 0) {
      result = new PriorityQueue<Object>(1, comp);
    }
    else {
      result = new PriorityQueue<Object>(sz, comp);
    }
    int idx = 0;
    while(idx < sz) {
      result.add(k.readClassAndObject(i));
      idx += 1;
    }
    return result;
  }