override def flatMap[U]()

in tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala [94:97]

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

  override def flatMap[U](newFn: T => TraversableOnce[U]) =
    new TwitterSpout(factory, limit, fieldName)(fn(_).flatMap(newFn))

  override def close { stream.shutdown }