def consume(self, consume_function):
from heronpy.streamlet.impl.consumebolt import ConsumeStreamlet<EOL>consume_streamlet = ConsumeStreamlet(consume_function, self)<EOL>self._add_child(consume_streamlet)<EOL>return<EOL>
Calls consume_function for each element of this streamlet. This function returns nothing