def onEmpty: Unit = Time.sleep()

in tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala [58:68]

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

  def onEmpty: Unit = Time.sleep(50)

  override def getSpout: IRichSpout = this

  override def flatMap[U](fn: T => TraversableOnce[U]) =
    new BaseSpout[U] {
      override def fieldName = self.fieldName
      override def onEmpty = self.onEmpty
      override def poll = self.poll.flatMap(fn)
      override def callOnOpen = self.callOnOpen
    }