#NEWLINE# @ return_future #NEWLINE# def consume( self , fragment , callback = None ) : #NEWLINE# #INDENT# '\n\n        ' #NEWLINE# self . _current_consumer ( fragment ) #NEWLINE# callback ( self . _message )