#NEWLINE# def test_close( self ) : #NEWLINE# #INDENT# self . q . push ( b'a' , 3 ) #NEWLINE# self . q . push ( b'b' , 1 ) #NEWLINE# self . q . push ( b'c' , 2 ) #NEWLINE# self . q . push ( b'd' , 1 ) #NEWLINE# iqueues = self . q . queues . values ( ) #NEWLINE# self . assertEqual ( sorted ( self . q . close ( ) ) , [ 1 , 2 , 3 ] ) #NEWLINE# assert all ( ( q . closed for q in iqueues ) )