#NEWLINE# def _consume( self , no_ack = False , prefetch = None , priority = None ) : #NEWLINE# #INDENT# 'Return a :py:class:_Consumer instance as a contextmanager, properly\n        shutting down the consumer when the generator is exited.\n\n        :param bool no_ack: Do not require acknowledgements\n        :param int prefetch: Set a prefetch count for the channel\n        :param int priority: Consumer priority\n        :return: _Consumer\n\n        ' #NEWLINE# if prefetch : #NEWLINE# #INDENT# self . channel . prefetch_count ( prefetch , False ) #NEWLINE# #UNINDENT# self . channel . _consume ( self , no_ack , self ) #NEWLINE# self . consuming = True