concurrent_pump: base template queue_reader class has been added