Package io.github.simplex.simplexss
Class ServicePool
java.lang.Object
io.github.simplex.simplexss.ServicePool
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescription(package private) void
addService
(IService service) (package private) static org.bukkit.NamespacedKey
reactor.core.scheduler.Scheduler
reactor.core.publisher.Mono<IService>
getService
(org.bukkit.NamespacedKey service_name) (package private) boolean
isValidService
(IService service) reactor.core.publisher.Mono<ServicePool>
recycle()
(package private) void
removeService
(IService service) reactor.core.publisher.Mono<reactor.core.Disposable>
startService
(org.bukkit.NamespacedKey service_name) reactor.core.publisher.Flux<reactor.core.Disposable>
reactor.core.publisher.Mono<Void>
stopService
(org.bukkit.NamespacedKey service_name) reactor.core.publisher.Mono<Void>
stopServices
(reactor.core.publisher.Flux<reactor.core.Disposable> disposableThread)
-
Field Details
-
associatedServices
-
scheduler
private final reactor.core.scheduler.Scheduler scheduler -
name
private final org.bukkit.NamespacedKey name -
DEFAULT
private static final org.bukkit.NamespacedKey DEFAULT
-
-
Constructor Details
-
ServicePool
public ServicePool(org.bukkit.NamespacedKey name, boolean multithreaded)
-
-
Method Details
-
getDefaultNamespacedKey
static org.bukkit.NamespacedKey getDefaultNamespacedKey() -
addService
-
isValidService
-
getAssociatedServices
-
startService
public reactor.core.publisher.Mono<reactor.core.Disposable> startService(org.bukkit.NamespacedKey service_name) -
startServices
public reactor.core.publisher.Flux<reactor.core.Disposable> startServices() -
stopServices
public reactor.core.publisher.Mono<Void> stopServices(reactor.core.publisher.Flux<reactor.core.Disposable> disposableThread) -
stopService
-
getService
-
removeService
-
recycle
-
getScheduler
public reactor.core.scheduler.Scheduler getScheduler()
-