#NEWLINE# def unregister_provider( self , provider ) : #NEWLINE# #INDENT# if ( not self . _consumers_ready . ready ( ) ) : #NEWLINE# #INDENT# self . _last_provider_unregistered . send ( ) #NEWLINE# return #NEWLINE# #UNINDENT# removed_event = Event ( ) #NEWLINE# self . _pending_remove_providers [ provider ] = removed_event #NEWLINE# removed_event . wait ( ) #NEWLINE# super ( QueueConsumer , self ) . unregister_provider ( provider )