void onUpdate()

in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java [249:265]

• 15 lines of code
• 6 McCabe index (conditional complexity)

    void onUpdate(AckStatus oldStatus, AckStatus ackStatus) {
      if (ackStatus == AckStatus.ACKED) {
        acked++;
      } else if (oldStatus == AckStatus.ACKED) {
        acked--;
      }

      if (ackStatus == AckStatus.CANCELED) {
        canceled++;
      } else if (oldStatus == AckStatus.CANCELED) {
        canceled--;
      }

      if (ackStatus == AckStatus.UNSET) {
        size--;
      }
    }