public void nextTuple()

in tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java [150:159]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public void nextTuple() {
    if(_serveTuples.size()>0) {
      FixedTuple ft = _serveTuples.remove(0);
      String id = UUID.randomUUID().toString();
      _pending.put(id, ft);
      _collector.emit(ft.stream, ft.values, id);
    } else {
      Utils.sleep(100);
    }
  }