private[utils] def send()

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

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

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