#NEWLINE# def notify_user( self , user_id ) : #NEWLINE# #INDENT# ( stream_id , _ ) = self . store . get_push_rules_stream_token ( ) #NEWLINE# self . notifier . on_new_event ( 'push_rules_key' , stream_id , users = [ user_id ] )