Package | Description |
---|---|
reactor.bus.registry |
Registries provide a common way to retrieve items registered using a
Selector . |
reactor.fn |
This package contains the foundational abstractions on which Reactor's functional and reactive components are
built.
|
reactor.fn.timer |
Modifier and Type | Interface and Description |
---|---|
interface |
Registration<K,V>
|
Modifier and Type | Class and Description |
---|---|
class |
CachableRegistration<K,V> |
Modifier and Type | Method and Description |
---|---|
Pausable |
Pausable.cancel()
Cancel this Pausable.
|
Pausable |
Pausable.pause()
Pause this Pausable.
|
Pausable |
Pausable.resume()
Unpause this Pausable.
|
Modifier and Type | Class and Description |
---|---|
static class |
HashWheelTimer.TimerPausable<T extends Consumer<Long>>
Timer Registration
|
Modifier and Type | Method and Description |
---|---|
Pausable |
HashWheelTimer.schedule(Consumer<Long> consumer,
long period,
TimeUnit timeUnit) |
Pausable |
Timer.schedule(Consumer<Long> consumer,
long period,
TimeUnit timeUnit)
Schedule a recurring task.
|
Pausable |
HashWheelTimer.schedule(Consumer<Long> consumer,
long period,
TimeUnit timeUnit,
long delayInMilliseconds) |
Pausable |
Timer.schedule(Consumer<Long> consumer,
long period,
TimeUnit timeUnit,
long delayInMilliseconds)
Schedule a recurring task.
|
Pausable |
HashWheelTimer.submit(Consumer<Long> consumer) |
Pausable |
Timer.submit(Consumer<Long> consumer)
Submit a task for arbitrary execution after the delay of this timer's resolution.
|
Pausable |
HashWheelTimer.submit(Consumer<Long> consumer,
long period,
TimeUnit timeUnit) |
Pausable |
Timer.submit(Consumer<Long> consumer,
long delay,
TimeUnit timeUnit)
Submit a task for arbitrary execution after the given time delay.
|
Copyright © 2017. All rights reserved.