def process_incoming_tuples(self):
<EOL>if self.output_helper.is_out_queue_available():<EOL><INDENT>self._read_tuples_and_execute()<EOL>self.output_helper.send_out_tuples()<EOL><DEDENT>else:<EOL><INDENT>self.bolt_metrics.update_out_queue_full_count()<EOL><DEDENT>
Should be called when tuple was buffered into in_stream

        This method is equivalent to ``addBoltTasks()`` but
        is designed for event-driven single-thread bolt.