def onEmpty: Unit = Time.sleep()

in tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala [83:92]

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

  def onEmpty: Unit = Time.sleep(50)

  override def nextTuple {
    Option(queue.poll).map(fn) match {
      case None => onEmpty
      case Some(items) => items.foreach { item =>
        collector.emit(new Values(item.asInstanceOf[AnyRef]))
      }
    }
  }