private Behavior onInternalSubscribeResponse()

in pekko-sample-distributed-data-java/src/main/java/sample/distributeddata/ReplicatedMetrics.java [178:186]

• 9 lines of code
• 5 McCabe index (conditional complexity)

  private Behavior<Command> onInternalSubscribeResponse(InternalSubscribeResponse rsp) {
    SubscribeResponse<LWWMap<String, Long>> rsp1 = rsp.rsp;
    if (rsp1 instanceof Changed && rsp1.key().equals(maxHeapKey)) {
      receiveMaxHeapChanged((Changed<LWWMap<String, Long>>) rsp1);
    } else if (rsp1 instanceof Changed && rsp1.key().equals(usedHeapKey)) {
      receiveUsedHeapChanged((Changed<LWWMap<String, Long>>) rsp1);
    }
    return this;
  }