Index (Omnibus 1.1.0 API)

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractFactoryOfTheFuture - Class in space.arim.omnibus.util.concurrent.impl: Abstract base class for FactoryOfTheFuture using protected method AbstractFactoryOfTheFuture.newIncompleteFuture() to generate futures as determined by subclasses.
AbstractFactoryOfTheFuture() - Constructor for class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
accept(E) - Method in interface space.arim.omnibus.events.EventConsumer: Acts on the event listened to
acceptAndContinue(E, EventFireController) - Method in interface space.arim.omnibus.events.AsynchronousEventConsumer: Acts on the event listened to, and resumes firing of event handlers in whichever context desired
acceptEither(CompletionStage, Consumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
acceptEither(CompletionStage, Consumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
acceptEitherAsync(CompletionStage, Consumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
acceptEitherAsync(CompletionStage, Consumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
acceptEitherAsync(CompletionStage, Consumer, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
acceptEitherAsync(CompletionStage, Consumer, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
acceptEitherSync(CompletionStage, Consumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
acceptEitherSync(CompletionStage, Consumer) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
acceptEitherSync(CompletionStage, Consumer) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
acceptEitherSync(CompletionStage, Consumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
allOf(Collection) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates a future which completes when all of the specified futures complete.
allOf(Collection) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
allOf(CentralisedFuture...) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates a future which completes when all of the specified futures complete.
allOf(CentralisedFuture...) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
applyToEither(CompletionStage, Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
applyToEither(CompletionStage, Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
applyToEitherAsync(CompletionStage, Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
applyToEitherAsync(CompletionStage, Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
applyToEitherAsync(CompletionStage, Function, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
applyToEitherAsync(CompletionStage, Function, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
applyToEitherSync(CompletionStage, Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
applyToEitherSync(CompletionStage, Function) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
applyToEitherSync(CompletionStage, Function) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
applyToEitherSync(CompletionStage, Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
ArraysUtil - Class in space.arim.omnibus.util: Utility class for manipulating arrays, particularly sorted arrays, reducing the need to write fast, error-prone array operations.
AsyncEvent - Interface in space.arim.omnibus.events: An event which is capable of having asynchronous listeners.
AsynchronousEventConsumer<E> - Interface in space.arim.omnibus.events: An asynchronous event consumer, which is responsible for continuing execution of the event

B

BaseCentralisedFuture<T> - Class in space.arim.omnibus.util.concurrent.impl: Implementation of CentralisedFuture using a SynchronousExecutor for Sync methods.
BaseCentralisedFuture(SynchronousExecutor) - Constructor for class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture: Creates a new incomplete future, with a SynchronousExecutor to use for executing tasks synchronously to the main thread.

C

calculateNextDelay(long, long) - Method in interface space.arim.omnibus.util.concurrent.DelayCalculator: Calculates the next delay, based on the previous delay and execution time.
cancel() - Method in interface space.arim.omnibus.events.Cancellable: Marks an event as cancelled.
cancel() - Method in interface space.arim.omnibus.util.concurrent.ScheduledTask: Cancels this scheduled task.
Cancellable - Interface in space.arim.omnibus.events: An event which may be cancelled via Cancellable.cancel().
CentralisedFuture<T> - Class in space.arim.omnibus.util.concurrent: An extended CompletableFuture API implementing ReactionStage.
CentralisedFuture() - Constructor for class space.arim.omnibus.util.concurrent.CentralisedFuture
compareTo(Registration) - Method in class space.arim.omnibus.registry.Registration
CompetitiveFuture<T> - Class in space.arim.omnibus.util.concurrent: A CompletableFuture with a specified default executor, which is used as the default executor in all future async operations.
CompetitiveFuture(Executor) - Constructor for class space.arim.omnibus.util.concurrent.CompetitiveFuture: Creates an incomplete future from the default executor to use
completeAsync(Supplier) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
completeAsync(Supplier, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
completedFuture(T) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates a precompleted future which has completed normally with the given value.
completedFuture(T) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
completedFuture(T, Executor) - Static method in class space.arim.omnibus.util.concurrent.CompetitiveFuture: Creates a precompleted future with the specified value.
completedStage(T) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates a precompleted stage which has completed normally with the given value.
completedStage(T) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
completeOnTimeout(T, long, TimeUnit) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
completeSync(Supplier) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
completeSync(Supplier) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
completeSync(Supplier) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
continueFire() - Method in interface space.arim.omnibus.events.EventFireController: Continues execution of the event fire.
contractAndRemove(T[], int) - Static method in class space.arim.omnibus.util.ArraysUtil: Copies all the elements in the target array, except the element at removalIndex, to a new array, and returns the resulting array.
contractFullString(String) - Static method in class space.arim.omnibus.util.UUIDUtil: Contracts the full form of a UUID string to its shortened form.
copy() - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
copyFuture(CompletableFuture) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Copies a CompletableFuture to a CentralisedFuture.
copyFuture(CompletableFuture) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
copyStage(CompletionStage) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Copies a CompletionStage to a ReactionStage.
copyStage(CompletionStage) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
createDefiner() - Method in interface space.arim.omnibus.spi.OmnibusProviderSpi: Creates the definer instance.

D

debugEntireDriverState(Appendable) - Method in interface space.arim.omnibus.events.EventBusDriver: Generates an extensive debug report for the entire driver
debugRegisteredListeners(Class) - Method in interface space.arim.omnibus.events.EventBusDriver: Generates brief debug report for an event class.
debugRegisteredListeners(Class, Appendable) - Method in interface space.arim.omnibus.events.EventBusDriver: Generates brief debug report for an event class.
defaultExecutor() - Method in class space.arim.omnibus.util.concurrent.CompetitiveFuture
DefaultOmnibus - Class in space.arim.omnibus: The default implementation of Omnibus.
DefaultOmnibus() - Constructor for class space.arim.omnibus.DefaultOmnibus: Creates an instance
DelayCalculator - Interface in space.arim.omnibus.util.concurrent: A delay calculator which calculates the next delay of a task based on both the previous delay and the execution time.
DelayCalculators - Class in space.arim.omnibus.util.concurrent: Provides default implementations for DelayCalculator, which determines delays for EnhancedExecutor's repeated scheduling methods.
DuplicateRegistrationException - Exception Class in space.arim.omnibus.registry: Thrown when it is attempted to register a Registration with the same provider as an existing registration.
DuplicateRegistrationException() - Constructor for exception class space.arim.omnibus.registry.DuplicateRegistrationException: Creates the exception.
DuplicateRegistrationException(String) - Constructor for exception class space.arim.omnibus.registry.DuplicateRegistrationException: Creates the exception with a detail message.
DuplicateRegistrationException(String, Throwable) - Constructor for exception class space.arim.omnibus.registry.DuplicateRegistrationException: Creates the exception with a detail message and a cause.
DuplicateRegistrationException(Throwable) - Constructor for exception class space.arim.omnibus.registry.DuplicateRegistrationException: Creates the exception with a cause.

E

EnhancedExecutor - Interface in space.arim.omnibus.util.concurrent: A Executor with upgraded concurrent functionality.
equals(Object) - Method in class space.arim.omnibus.registry.Registration
Event - Interface in space.arim.omnibus.events: Marker interface for an event which is fired and listened to using EventBus.
EventBus - Interface in space.arim.omnibus.events: A framework for firing events and listening to them.
EventBusDriver - Interface in space.arim.omnibus.events: A low-level complement to a EventBus.
EventConsumer<E> - Interface in space.arim.omnibus.events: A listener to an event
EventFireController - Interface in space.arim.omnibus.events: A controller used to resume firing of an event
exceptionally(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
exceptionally(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
execute(Runnable) - Method in interface space.arim.omnibus.util.concurrent.EnhancedExecutor: Executes an asynchronous action.
execute(Runnable) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Executes a Runnable asynchronously.
execute(Runnable) - Method in interface space.arim.omnibus.util.concurrent.FileSystemIOExecutor: Executes an operation involving considerable filesystem IO.
execute(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
execute(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor: Runs the specified command.
execute(Runnable) - Method in interface space.arim.omnibus.util.concurrent.NetworkIOExecutor: Executes an operation involving considerable networking IO.
executeSync(Runnable) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Runs the Runnable on the main thread, if the application has a main thread, else executes it in a thread pool suitable for computational work such as ForkJoinPool.commonPool()
executeSync(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentFactoryOfTheFuture
executeSync(Runnable) - Method in interface space.arim.omnibus.util.concurrent.SynchronousExecutor: Runs the Runnable on the main thread, if the application has a main thread, else executes it in a thread pool suitable for computational work such as ForkJoinPool.commonPool()
ExecutorServiceFactory - Interface in space.arim.omnibus.util.concurrent: Factory of ExecutorServices
expandAndInsert(T[], T, int) - Static method in class space.arim.omnibus.util.ArraysUtil: Creates a new array of the source array's length plus 1, then copies all the elements before the insertion index from the source array to the new array, and copies all elements after the insertion index to the new array.
expandShortString(String) - Static method in class space.arim.omnibus.util.UUIDUtil: Expands a shortened version of a UUID to the full string form.

F

FactoryOfTheFuture - Interface in space.arim.omnibus.util.concurrent: Concurrent executor and producer of CentralisedFuture.
failedFuture(Throwable) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates a precompleted future which has completed exceptionally with the given exception.
failedFuture(Throwable) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
failedFuture(Throwable, Executor) - Static method in class space.arim.omnibus.util.concurrent.CompetitiveFuture: Creates a future completed exceptionally with the specified exception.
failedStage(Throwable) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates a precompleted stage which has completed exceptionally with the given exception.
failedStage(Throwable) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
FileSystemIOExecutor - Interface in space.arim.omnibus.util.concurrent: An executor whose details are tuned for specialising in handling work related to filesystem IO.
fireAsyncEvent(E) - Method in interface space.arim.omnibus.events.EventBus: Fires an asynchronous capable event, invoking all applicable listeners.
fireAsyncEventWithoutFuture(E) - Method in interface space.arim.omnibus.events.EventBus: Fires an asynchronous capable event, invoking all applicable listeners.
fireEvent(E) - Method in interface space.arim.omnibus.events.EventBus: Fires an event, invoking all applicable listeners.
fireEvent(Object) - Method in interface space.arim.omnibus.events.EventBusDriver: Fires an event, with the normal restriction that the event implement Event relaxed.
fixedDelay() - Static method in class space.arim.omnibus.util.concurrent.DelayCalculators: Schedules at a constant delay between executions.
fixedRate() - Static method in class space.arim.omnibus.util.concurrent.DelayCalculators: Schedules at a fixed rate of delay, meaning execution initiates at constant intervals.
fromByteArray(byte[]) - Static method in class space.arim.omnibus.util.UUIDUtil: Reads a UUID from a byte array.
fromByteArray(byte[], int) - Static method in class space.arim.omnibus.util.UUIDUtil: Reads a UUID from a byte array with a specified offset.
fromShortString(String) - Static method in class space.arim.omnibus.util.UUIDUtil: Converts a short form uuid string to a UUID.

G

get() - Static method in class space.arim.omnibus.util.ThisClass: Gets the literal class which called this method.
getAllRegistrations(Class) - Method in interface space.arim.omnibus.registry.Registry: Gets all registrations for a specific service, as an immutable copy.
getDriver() - Method in interface space.arim.omnibus.events.EventBus: Gets the lower level event bus driver.
getEventBus() - Method in class space.arim.omnibus.DefaultOmnibus
getEventBus() - Method in interface space.arim.omnibus.Omnibus: Gets the event bus used.
getName() - Method in class space.arim.omnibus.registry.Registration: Gets a friendly display name for the service.
getOmnibus() - Static method in class space.arim.omnibus.OmnibusProvider: Gets the central Omnibus instance.
getOmnibus(Class) - Method in interface space.arim.omnibus.spi.OmnibusDefiner: Gets an Omnibus instance for the given caller class.
getPrevious() - Method in interface space.arim.omnibus.registry.ServiceChangeEvent: Gets the previous highest priority registration.
getPriority() - Method in class space.arim.omnibus.registry.Registration: The priority of this registration.
getProvider() - Method in class space.arim.omnibus.registry.Registration: Gets the provider, or the actual service.
getProvider(Class) - Method in interface space.arim.omnibus.registry.Registry: Finds the highest priority registration for a service and returns its provider.
getRegisteredListenerCount(Class) - Method in interface space.arim.omnibus.events.EventBusDriver: Gets the amount of registered listeners which would be called if an instance of the specified event class is fired.
getRegistration() - Method in interface space.arim.omnibus.registry.RegistrationAddEvent: Gets the registration added.
getRegistration() - Method in interface space.arim.omnibus.registry.RegistrationRemoveEvent: Gets the registration which was unregistered.
getRegistration(Class) - Method in interface space.arim.omnibus.registry.Registry: Retrieves the highest priority registration for a service.
getRegistry() - Method in class space.arim.omnibus.DefaultOmnibus
getRegistry() - Method in interface space.arim.omnibus.Omnibus: Gets the service registry.
getService() - Method in interface space.arim.omnibus.registry.RegistryEvent: Gets the service involved in this event.
getUpdated() - Method in interface space.arim.omnibus.registry.ServiceChangeEvent: Gets the updated highest priority registration.

H

handle(BiFunction) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
handle(BiFunction) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
handleAsync(BiFunction) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
handleAsync(BiFunction) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
handleAsync(BiFunction, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
handleAsync(BiFunction, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
handleSync(BiFunction) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
handleSync(BiFunction) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
handleSync(BiFunction) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
handleSync(BiFunction) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
hashCode() - Method in class space.arim.omnibus.registry.Registration
HIGH - Static variable in class space.arim.omnibus.events.ListenerPriorities
HIGH - Static variable in class space.arim.omnibus.registry.RegistryPriorities
HIGHER - Static variable in class space.arim.omnibus.events.ListenerPriorities
HIGHER - Static variable in class space.arim.omnibus.registry.RegistryPriorities
HIGHEST - Static variable in class space.arim.omnibus.events.ListenerPriorities
HIGHEST - Static variable in class space.arim.omnibus.registry.RegistryPriorities

I

IndifferentCentralisedFuture<T> - Class in space.arim.omnibus.util.concurrent.impl: CentralisedFuture implementation which regards Sync method calls as identical to Async calls using the default executor.
IndifferentCentralisedFuture() - Constructor for class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
IndifferentFactoryOfTheFuture - Class in space.arim.omnibus.util.concurrent.impl: FactoryOfTheFuture implementation which regards Sync method calls to the CentralisedFutures produced by the factory as identical to Async calls using the default executor.
IndifferentFactoryOfTheFuture() - Constructor for class space.arim.omnibus.util.concurrent.impl.IndifferentFactoryOfTheFuture
isCancelled() - Method in interface space.arim.omnibus.events.Cancellable: Whether the event has been cancelled, possibly by another listener.
isCancelled() - Method in interface space.arim.omnibus.util.concurrent.ScheduledTask: Whether this task is cancelled
isDone() - Method in interface space.arim.omnibus.util.concurrent.ScheduledTask: Whether this task is cancelled, or is a delayed task and has been run
isProvidedFor(Class) - Method in interface space.arim.omnibus.registry.Registry: Checks whether a service has any accompanying provider

This method should only be used in the rare case where one needs to check whether a service is registered but does not need to retrieve the registration itself.
isRepeating() - Method in interface space.arim.omnibus.util.concurrent.ScheduledTask: Whether this is a repeating task or a one time delayed task

J

JDKExecutorServiceFactory - Class in space.arim.omnibus.util.concurrent.impl: An ExecutorServiceFactory which uses the JDK executor implementations returned from Executors
JDKExecutorServiceFactory() - Constructor for class space.arim.omnibus.util.concurrent.impl.JDKExecutorServiceFactory

L

ListenerPriorities - Class in space.arim.omnibus.events: Class containing priority constants for referential use.
ListeningMethod - Annotation Type in space.arim.omnibus.events: Placed on methods to indicate it is intended they listen to an event.
LOW - Static variable in class space.arim.omnibus.events.ListenerPriorities
LOW - Static variable in class space.arim.omnibus.registry.RegistryPriorities
LOWER - Static variable in class space.arim.omnibus.events.ListenerPriorities
LOWER - Static variable in class space.arim.omnibus.registry.RegistryPriorities
LOWEST - Static variable in class space.arim.omnibus.events.ListenerPriorities
LOWEST - Static variable in class space.arim.omnibus.registry.RegistryPriorities

M

minimalCompletionStage() - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
minimalCompletionStage() - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
minimalCompletionStage() - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture

N

NetworkIOExecutor - Interface in space.arim.omnibus.util.concurrent: An executor whose details are tuned for specialising in handling work related to networking IO.
newCachedThreadPool() - Method in interface space.arim.omnibus.util.concurrent.ExecutorServiceFactory: Creates an executor service backed by a cached thread pool
newCachedThreadPool() - Method in class space.arim.omnibus.util.concurrent.impl.JDKExecutorServiceFactory
newCachedThreadPool(ThreadFactory) - Method in interface space.arim.omnibus.util.concurrent.ExecutorServiceFactory: Creates an executor service backed by a cached thread pool
newCachedThreadPool(ThreadFactory) - Method in class space.arim.omnibus.util.concurrent.impl.JDKExecutorServiceFactory
newFixedThreadPool(int) - Method in interface space.arim.omnibus.util.concurrent.ExecutorServiceFactory: Creates an executor service backed by a fixed number of threads
newFixedThreadPool(int) - Method in class space.arim.omnibus.util.concurrent.impl.JDKExecutorServiceFactory
newFixedThreadPool(int, ThreadFactory) - Method in interface space.arim.omnibus.util.concurrent.ExecutorServiceFactory: Creates an executor service backed by a fixed number of threads
newFixedThreadPool(int, ThreadFactory) - Method in class space.arim.omnibus.util.concurrent.impl.JDKExecutorServiceFactory
newIncompleteFuture() - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
newIncompleteFuture() - Method in class space.arim.omnibus.util.concurrent.CompetitiveFuture
newIncompleteFuture() - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Creates an incomplete future.
newIncompleteFuture() - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture: Creates a new, incomplete future.
newIncompleteFuture() - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
newIncompleteFuture() - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
newIncompleteFuture() - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentFactoryOfTheFuture
NORMAL - Static variable in class space.arim.omnibus.events.ListenerPriorities
NORMAL - Static variable in class space.arim.omnibus.registry.RegistryPriorities

O

Omnibus - Interface in space.arim.omnibus: Central provider of the event bus and service registry.
OmnibusDefiner - Interface in space.arim.omnibus.spi: Manager responsible for returning Omnibus instances
OmnibusProvider - Class in space.arim.omnibus: Instance holder for the central Omnibus instance.
OmnibusProviderSpi - Interface in space.arim.omnibus.spi: Service provider interface allowing replacement of the default OmnibusDefiner
orTimeout(long, TimeUnit) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture

P

priority() - Element in annotation type space.arim.omnibus.events.ListeningMethod: The priority at which to listen.
priority() - Method in interface space.arim.omnibus.spi.OmnibusProviderSpi: The priority of this provider.

R

ReactionStage<T> - Interface in space.arim.omnibus.util.concurrent: An extended interface to CompletionStage providing a fourth variant of methods in the form do, doAsync, doAsync; doSync, where do is the general stage consuming operation.
register(Class, byte, T, String) - Method in interface space.arim.omnibus.registry.Registry: Registers a resource as a specific service and generates a Registration to represent the registration which was just added.
registerAndGet(Class, byte, T, String) - Method in interface space.arim.omnibus.registry.Registry: Registers a resource as a specific service and returns the highest priority registration for the service.
RegisteredListener - Interface in space.arim.omnibus.events: Marker for a listener registered with a EventBus.
registerListener(Class, byte, Consumer) - Method in interface space.arim.omnibus.events.EventBusDriver: Registers a listener, with the normal restriction that the event implement Event relaxed.
registerListener(Class, byte, AsynchronousEventConsumer) - Method in interface space.arim.omnibus.events.EventBus: Creates and registers an asynchronous listener, returning the created listener.
registerListener(Class, byte, EventConsumer) - Method in interface space.arim.omnibus.events.EventBus: Creates and registers a listener, returning the created listener.
registerListeningMethods(Object) - Method in interface space.arim.omnibus.events.EventBus: Registers all methods on the target listener object which are annotated with ListeningMethod.
Registration<T> - Class in space.arim.omnibus.registry: A registration wrapper for a specific service, including a registration priority, service provider implementing the service, and accompanying optional display name.
Registration(byte, T, String) - Constructor for class space.arim.omnibus.registry.Registration: Creates from a priority, provider, and display name.
RegistrationAddEvent<T> - Interface in space.arim.omnibus.registry: Indicates a registration was registered.
RegistrationRemoveEvent<T> - Interface in space.arim.omnibus.registry: Indicates a registration was removed via unregistration.
Registry - Interface in space.arim.omnibus.registry: A framework for registering and loading services.
RegistryEvent<T> - Interface in space.arim.omnibus.registry: An event related to a registration or unregistration which happened in a Registry.
RegistryPriorities - Class in space.arim.omnibus.registry: Class containing priority constants for referential use

See Registry.register(Class, byte, Object, String) for more information on priorities.
requiresCallerClass() - Method in interface space.arim.omnibus.spi.OmnibusDefiner: Whether this provider requires that the caller class be looked up.
requiresExecutionTime() - Method in interface space.arim.omnibus.util.concurrent.DelayCalculator: Whether the execution time passed to DelayCalculator.calculateNextDelay(long, long) is used.
runAfterBoth(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterBoth(CompletionStage, Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterBothAsync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterBothAsync(CompletionStage, Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterBothAsync(CompletionStage, Runnable, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterBothAsync(CompletionStage, Runnable, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterBothSync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterBothSync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
runAfterBothSync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
runAfterBothSync(CompletionStage, Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterEither(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterEither(CompletionStage, Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterEitherAsync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterEitherAsync(CompletionStage, Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterEitherAsync(CompletionStage, Runnable, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterEitherAsync(CompletionStage, Runnable, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAfterEitherSync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
runAfterEitherSync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
runAfterEitherSync(CompletionStage, Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
runAfterEitherSync(CompletionStage, Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
runAsync(Runnable) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Runs a Runnable asynchronously and returns a future indicating its progress.
runAsync(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
runAsync(Runnable, Executor) - Static method in class space.arim.omnibus.util.concurrent.CompetitiveFuture: Runs an action asynchronously.
runAsync(Runnable, Executor) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Runs a Runnable asynchronously using the provided Executor and returns a future indicating its progress.
runAsync(Runnable, Executor) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
runSync(Runnable) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Runs a Runnable on the main thread if a main thread exists, else appropriately, per the specifications of SynchronousExecutor.executeSync(Runnable).
runSync(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture

S

ScheduledTask - Interface in space.arim.omnibus.util.concurrent: A delayed or repeating task scheduled with a EnhancedExecutor.
scheduleOnce(Runnable, Duration) - Method in interface space.arim.omnibus.util.concurrent.EnhancedExecutor: Schedules a delayed task
scheduleOnce(Runnable, Duration) - Method in class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor
scheduleRepeating(Runnable, Duration, DelayCalculator) - Method in interface space.arim.omnibus.util.concurrent.EnhancedExecutor: Schedules a repeating task
scheduleRepeating(Runnable, Duration, DelayCalculator) - Method in class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor
scheduleRepeating(Consumer, Duration, DelayCalculator) - Method in interface space.arim.omnibus.util.concurrent.EnhancedExecutor: Schedules a repeating task
scheduleRepeating(Consumer, Duration, DelayCalculator) - Method in class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor
ServiceChangeEvent<T> - Interface in space.arim.omnibus.registry: Indicates the prioritised provider for a specific service changed.
SimplifiedEnhancedExecutor - Class in space.arim.omnibus.util.concurrent.impl: Abstract implementation of EnhancedExecutor which handles its own scheduling and delegates execution to subclasses' SimplifiedEnhancedExecutor.execute(Runnable) methods.
SimplifiedEnhancedExecutor() - Constructor for class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor: Creates an instance
space.arim.omnibus - module space.arim.omnibus
space.arim.omnibus - package space.arim.omnibus
space.arim.omnibus.events - package space.arim.omnibus.events
space.arim.omnibus.registry - package space.arim.omnibus.registry
space.arim.omnibus.spi - package space.arim.omnibus.spi: Defines a service provider framework allowing management of instances returned by OmnibusProvider.getOmnibus().
space.arim.omnibus.util - package space.arim.omnibus.util
space.arim.omnibus.util.concurrent - package space.arim.omnibus.util.concurrent: Core interfaces for concurrency-related classes.
space.arim.omnibus.util.concurrent.impl - package space.arim.omnibus.util.concurrent.impl: Contains base implementations for interfaces from the concurrency frameworks defined by space.arim.omnibus.util.concurrent
submit(Runnable) - Method in interface space.arim.omnibus.util.concurrent.EnhancedExecutor: Execute an asynchronous action using this executor.
submit(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor
supply(Supplier) - Method in interface space.arim.omnibus.util.concurrent.EnhancedExecutor: Supplies a value asynchronously using this executor.
supply(Supplier) - Method in class space.arim.omnibus.util.concurrent.impl.SimplifiedEnhancedExecutor
supplyAsync(Supplier) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Supplies a value asynchronously and returns a future indicating its progress.
supplyAsync(Supplier) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
supplyAsync(Supplier, Executor) - Static method in class space.arim.omnibus.util.concurrent.CompetitiveFuture: Supplies a value asynchronously.
supplyAsync(Supplier, Executor) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Supplies a value asynchronously using the provided Executor and returns a future indicating its progress.
supplyAsync(Supplier, Executor) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
supplySync(Supplier) - Method in interface space.arim.omnibus.util.concurrent.FactoryOfTheFuture: Supplies a value on the main thread if a main thread exists, else appropriately, per the specifications of SynchronousExecutor.executeSync(Runnable).
supplySync(Supplier) - Method in class space.arim.omnibus.util.concurrent.impl.AbstractFactoryOfTheFuture
SynchronousExecutor - Interface in space.arim.omnibus.util.concurrent: Similar to Executor, in that it accepts and runs Runnables.

T

thenAccept(Consumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAccept(Consumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptAsync(Consumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptAsync(Consumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptAsync(Consumer, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptAsync(Consumer, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptBoth(CompletionStage, BiConsumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptBoth(CompletionStage, BiConsumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptBothAsync(CompletionStage, BiConsumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptBothAsync(CompletionStage, BiConsumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptBothAsync(CompletionStage, BiConsumer, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptBothAsync(CompletionStage, BiConsumer, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptBothSync(CompletionStage, BiConsumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptBothSync(CompletionStage, BiConsumer) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
thenAcceptBothSync(CompletionStage, BiConsumer) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
thenAcceptBothSync(CompletionStage, BiConsumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenAcceptSync(Consumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenAcceptSync(Consumer) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
thenAcceptSync(Consumer) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
thenAcceptSync(Consumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenApply(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenApply(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenApplyAsync(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenApplyAsync(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenApplyAsync(Function, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenApplyAsync(Function, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenApplySync(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenApplySync(Function) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
thenApplySync(Function) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
thenApplySync(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenCombine(CompletionStage, BiFunction) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenCombine(CompletionStage, BiFunction) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenCombineAsync(CompletionStage, BiFunction) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenCombineAsync(CompletionStage, BiFunction) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenCombineAsync(CompletionStage, BiFunction, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenCombineAsync(CompletionStage, BiFunction, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenCombineSync(CompletionStage, BiFunction) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenCombineSync(CompletionStage, BiFunction) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
thenCombineSync(CompletionStage, BiFunction) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
thenCombineSync(CompletionStage, BiFunction) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenCompose(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenCompose(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenComposeAsync(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenComposeAsync(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenComposeAsync(Function, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenComposeAsync(Function, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenComposeSync(Function) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenComposeSync(Function) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
thenComposeSync(Function) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
thenComposeSync(Function) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenRun(Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenRun(Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenRunAsync(Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenRunAsync(Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenRunAsync(Runnable, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenRunAsync(Runnable, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
thenRunSync(Runnable) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
thenRunSync(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
thenRunSync(Runnable) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
thenRunSync(Runnable) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
ThisClass - Class in space.arim.omnibus.util: Simple utility to get one's own literal class, including in a static context.
toByteArray(UUID) - Static method in class space.arim.omnibus.util.UUIDUtil: Creates a byte array and writes a UUID to it.
toByteArray(UUID, byte[], int) - Static method in class space.arim.omnibus.util.UUIDUtil: Writes a UUID to a byte array at the specified offset.
toCompletableFuture() - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
toCompletableFuture() - Method in interface space.arim.omnibus.util.concurrent.ReactionStage: Converts to an equivalent CentralisedFuture with the same completion properties as this.
toShortString(UUID) - Static method in class space.arim.omnibus.util.UUIDUtil: Converts a UUID to its short form string representation.
toString() - Method in class space.arim.omnibus.DefaultOmnibus
toString() - Method in class space.arim.omnibus.registry.Registration

U

unregister(Class, Registration) - Method in interface space.arim.omnibus.registry.Registry: Unregisters the specified Registration, and returns the updated highest priority registration after the specified Registration is unregistered.
unregisterListener(RegisteredListener) - Method in interface space.arim.omnibus.events.EventBus: Unregister a registered listener.
unregisterListeningMethods(Object) - Method in interface space.arim.omnibus.events.EventBus: Unregisters any methods on the target listener object which are annotated with ListeningMethod and were previously registered.
UUIDUtil - Class in space.arim.omnibus.util: Utility class for manipulating valid UUIDs.

V

variableRate(LongUnaryOperator) - Static method in class space.arim.omnibus.util.concurrent.DelayCalculators: A more complicated version of DelayCalculators.fixedRate().

W

whenComplete(BiConsumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
whenComplete(BiConsumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
whenCompleteAsync(BiConsumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
whenCompleteAsync(BiConsumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
whenCompleteAsync(BiConsumer, Executor) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
whenCompleteAsync(BiConsumer, Executor) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage
whenCompleteSync(BiConsumer) - Method in class space.arim.omnibus.util.concurrent.CentralisedFuture
whenCompleteSync(BiConsumer) - Method in class space.arim.omnibus.util.concurrent.impl.BaseCentralisedFuture
whenCompleteSync(BiConsumer) - Method in class space.arim.omnibus.util.concurrent.impl.IndifferentCentralisedFuture
whenCompleteSync(BiConsumer) - Method in interface space.arim.omnibus.util.concurrent.ReactionStage

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form