private def latestSeqNoF()

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

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

  private def latestSeqNoF(partition: PartitionId): Future[SequenceNumber] =
    getRunTimeInfoF(partition).map(_.getLastEnqueuedSequenceNumber + 1)

  /**
   * The number of partitions in the EventHubs instance.
   *
   * @return partition count
   */
  override def partitionCount: Int = {
    try {
      if (ehConf.dynamicPartitionDiscovery) {
        partitionCountDynamic
      } else {
        partitionCountLazyVal
      }
    } catch {
      case e: Exception => throw e
    }
  }