#NEWLINE# def fetch( self , now ) : #NEWLINE# #INDENT# 'Fetch any objects that have timed out\n\n        Args:\n            now (ms): Current time in msec\n\n        Returns:\n            list: List of objects that have timed out\n        ' #NEWLINE# now_key = int ( ( self / self . bucket_size ) ) #NEWLINE# ret = [ ] #NEWLINE# while ( self . entries and ( self . entries [ 0 ] . end_key <= now_key ) ) : #NEWLINE# #INDENT# ret . extend ( self . entries . pop ( 0 ) . queue ) #NEWLINE# #UNINDENT# return ret