add helper method for ActivityDefObserver application

This commit is contained in:
Jonathan Shook 2022-06-09 15:01:22 -05:00
parent 5b8ed36f49
commit 5dbfa385a8

View File

@ -25,4 +25,12 @@ import io.nosqlbench.engine.api.activityimpl.ActivityDef;
*/
public interface ActivityDefObserver {
void onActivityDefUpdate(ActivityDef activityDef);
static void apply(ActivityDef def, Object... candidates) {
for (Object candidate : candidates) {
if (candidate instanceof ActivityDefObserver observer) {
observer.onActivityDefUpdate(def);
}
}
}
}