#NEWLINE# def test_worker_sends_resets_asr_engine_when_it_doesnt_receive_any_chunk_for_1sec( self ) : #NEWLINE# #INDENT# messages = [ { #NEWLINE# #INDENT# 'frontend' : self . make_frontend_request ( 'message 1' , 'ONLINE' , has_next = True ) , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'time' : ( + 1 ) , #NEWLINE# #UNINDENT# } ] #NEWLINE# self . run_worker ( self ) #NEWLINE# self . assertTrue ( self . asr . resetted )