mirror of
https://github.com/nosqlbench/nosqlbench.git
synced 2025-02-25 18:55:28 -06:00
consolidate calling method, remove old invocation path for activity executor
This commit is contained in:
@@ -171,18 +171,6 @@ class ActivityExecutorTest {
|
||||
}
|
||||
}
|
||||
|
||||
private MotorDispenser<?> getActivityMotorFactory(final Action lc, Input ls) {
|
||||
return new MotorDispenser<>() {
|
||||
@Override
|
||||
public Motor getMotor(final ActivityDef activityDef, final int slotId) {
|
||||
final Activity activity = new SimpleActivity(activityDef, NBLabeledElement.forMap(Map.of()));
|
||||
final Motor<?> cm = new CoreMotor<>(activity, slotId, ls);
|
||||
cm.setAction(lc);
|
||||
return cm;
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
private SyncAction motorActionDelay(long delay) {
|
||||
return new SyncAction() {
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user