#NEWLINE# def _wait_ready( self , now ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# first = self . queued [ 0 ] #NEWLINE# #UNINDENT# except IndexError : #NEWLINE# #INDENT# self . wake . wait ( ) #NEWLINE# self . wake . clear ( ) #NEWLINE# return #NEWLINE# #UNINDENT# first_timestamp = first [ 0 ] #NEWLINE# if ( first_timestamp > now ) : #NEWLINE# #INDENT# self . wake . wait ( ( first_timestamp - now ) ) #NEWLINE# self . wake . clear ( )