override def allBoundedSeqNos: Map[PartitionId,()

in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala [124:139]

• 16 lines of code
• 4 McCabe index (conditional complexity)

  override def allBoundedSeqNos: Map[PartitionId, (SequenceNumber, SequenceNumber)] = {
    val futures = for (i <- 0 until partitionCount)
      yield
        getRunTimeInfoF(i) map { r =>
          val earliest =
            if (r.getBeginSequenceNumber == -1L) 0L
            else {
              if (r.getIsEmpty) r.getLastEnqueuedSequenceNumber + 1 else r.getBeginSequenceNumber
            }
          val latest = r.getLastEnqueuedSequenceNumber + 1
          i -> ((earliest, latest): (Long, Long))
        }
    Await
      .result(Future.sequence(futures), ehConf.internalOperationTimeout)
      .toMap
  }