private[utils] def send()

in core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala [86:101]

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

  private[utils] def send(partition: Option[PartitionId],
                          events: Seq[Int],
                          properties: Option[Map[String, Object]]): Seq[Int] = {
    if (partition.isDefined) {
      partitions(partition.get).send(events, properties)
    } else {
      for (event <- events) {
        synchronized {
          val part = count % this.partitionCount
          count += 1
          this.send(Some(part), Seq(event), properties)
        }
      }
    }
    events
  }