def apply()

in tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala [39:47]

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

  def apply(
    factory: TwitterStreamFactory,
    limit: Int = QUEUE_LIMIT,
    fieldName: String = FIELD_NAME): TwitterSpout[Status] =
    new TwitterSpout(factory, limit, fieldName)(i => Some(i))
}

class TwitterSpout[+T](factory: TwitterStreamFactory, limit: Int, fieldName: String)(fn: Status => TraversableOnce[T])
    extends BaseRichSpout with Spout[T] {