override def get()

in storehaus-core/src/main/scala/com/twitter/storehaus/TunableReplicatedStore.scala [157:168]

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

  override def get(k: K): Future[Option[V]] = {
    doGet(k).map { r : (Option[V], Seq[Int]) =>
      val (response, successes) = r
      if (readRepair && readConsistency == ConsistencyLevel.Quorum) {
        // optionally, perform read-repair (best effort)
        stores.zipWithIndex.foreach { case (s, i) =>
          if (!successes.contains(i)) s.put((k, response))
        }
      }
      response
    }
  }