21 lines
464 B
Java
21 lines
464 B
Java
package it.tdlight.reactiveapi;
|
|
|
|
import java.util.concurrent.Executor;
|
|
import org.jetbrains.annotations.NotNull;
|
|
import reactor.core.scheduler.Scheduler;
|
|
|
|
@SuppressWarnings("ClassCanBeRecord")
|
|
public class SchedulerExecutor implements Executor {
|
|
|
|
private final Scheduler scheduler;
|
|
|
|
public SchedulerExecutor(Scheduler scheduler) {
|
|
this.scheduler = scheduler;
|
|
}
|
|
|
|
@Override
|
|
public void execute(@NotNull Runnable command) {
|
|
scheduler.schedule(command);
|
|
}
|
|
}
|