#NEWLINE# @ defer . inlineCallbacks #NEWLINE# def eomReceived( self ) : #NEWLINE# #INDENT# message = self . parser . close ( ) #NEWLINE# self . parser = parser . FeedParser ( ) #NEWLINE# processor = ( yield self . processor_dependency . wait_for_resource ( ) ) #NEWLINE# baton = dict ( message = message , from_addr = self . from_addr , to_addr = self . to_addr ) #NEWLINE# if ( self . avatar_id is not Ellipsis ) : #NEWLINE# #INDENT# baton [ 'avatar_id' ] = self . avatar_id #NEWLINE# #UNINDENT# ( yield processor ( processor ) ) #NEWLINE# defer . returnValue ( None )