question: public void executeBlocking ( String desc , BlockingConsumer < MongoClient > operation ) throws InterruptedException { while ( true ) { MongoClient primary = primaryConnectionSupplier . get ( ) ; try { operation . accept ( primary ) ; return ; } catch ( Throwable t ) { errorHandler . accept ( desc , t ) ; } } }
target:  Execute the supplied operation using the primary, blocking until a primary is available. Whenever the operation stops (e.g., if the primary is no longer primary), then restart the operation using the current primary.