<s> from itertools import cycle <EOL> from streamparse import Spout <EOL> class WordSpout ( Spout ) : <EOL> outputs = [ '<STR_LIT>' ] <EOL> def initialize ( self , stormconf , context ) : <EOL> self . words = cycle ( [ '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' ] ) <EOL> def next_tuple ( self ) : <EOL> word = next ( self . words ) <EOL> self . emit ( [ word ] ) </s>
