#NEWLINE# @ defer . inlineCallbacks #NEWLINE# def _handle_new_events( self , origin , event_infos , backfilled = False , outliers = False ) : #NEWLINE# #INDENT# contexts = ( yield defer . gatherResults ( [ self . _prep_event ( origin , ev_info [ 'event' ] , state = ev_info . get ( 'state' ) , auth_events = ev_info . get ( 'auth_events' ) ) for ev_info in self ] ) ) #NEWLINE# ( yield self . store . persist_events ( [ ( ev_info [ 'event' ] , context ) for ( ev_info , context ) in itertools . izip ( event_infos , contexts ) ] , backfilled = backfilled , is_new_state = ( ( not outliers ) and ( not backfilled ) ) ) )