Package | Description |
---|---|
reactor | |
reactor.bus.timer | |
reactor.fn.timer | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.aggregation | |
reactor.rx.action.control | |
reactor.rx.action.error | |
reactor.rx.action.filter | |
reactor.rx.stream |
Modifier and Type | Method and Description |
---|---|
Timer |
Environment.getTimer()
Get the
Environment -wide HashWheelTimer . |
static Timer |
Environment.timer()
Obtain the default timer from the current environment.
|
Modifier and Type | Class and Description |
---|---|
class |
EventTimer
|
Modifier and Type | Class and Description |
---|---|
class |
HashWheelTimer
Hash Wheel Timer, as per the paper:
Hashed and hierarchical timing wheels:
http://www.cs.columbia.edu/~nahum/w6998/papers/ton97-timing-wheels.pdf
More comprehensive slides, explaining the paper can be found here:
http://www.cse.wustl.edu/~cdgill/courses/cs6874/TimingWheels.ppt
Hash Wheel timer is an approximated timer that allows performant execution of
larger amount of tasks with better performance compared to traditional scheduling.
|
Modifier and Type | Method and Description |
---|---|
static Timer |
TimeUtils.getTimer() |
Modifier and Type | Method and Description |
---|---|
static void |
TimeUtils.setTimer(Timer timer) |
Modifier and Type | Method and Description |
---|---|
Timer |
Stream.getTimer()
Get the current timer available if any or try returning the shared Environment one (which may cause an exception
if no Environment has been globally initialized)
|
Modifier and Type | Method and Description |
---|---|
Stream<List<O>> |
Stream.buffer(int maxSize,
long timespan,
TimeUnit unit,
Timer timer)
Collect incoming values into a
List that will be pushed into the returned Stream every
timespan OR maxSize items |
Stream<List<O>> |
Stream.buffer(long timespan,
long timeshift,
TimeUnit unit,
Timer timer)
Collect incoming values into multiple
List buckets created every timeshift that will be pushed
into the returned Stream every
timespan. |
Stream<List<O>> |
Stream.buffer(long timespan,
TimeUnit unit,
Timer timer)
Collect incoming values into a
List that will be pushed into the returned Stream every
timespan. |
static Stream<Long> |
Streams.period(Timer timer,
long period)
Build a Stream that will emit ever increasing counter from 0 after on each period from the subscribe
call.
|
static Stream<Long> |
Streams.period(Timer timer,
long delay,
long period)
Build a Stream that will emit ever increasing counter from 0 after the time delay on each period.
|
static Stream<Long> |
Streams.period(Timer timer,
long delay,
long period,
TimeUnit unit)
Build a Stream that will emit ever increasing counter from 0 after the time delay on each period.
|
static Stream<Long> |
Streams.period(Timer timer,
long period,
TimeUnit unit)
Build a Stream that will emit ever increasing counter from 0 after the subscribe call on each period.
|
Stream<O> |
Stream.sample(int maxSize,
long timespan,
TimeUnit unit,
Timer timer)
Create a new
Stream whose values will be only the last value of each batch. |
Stream<O> |
Stream.sample(long timespan,
TimeUnit unit,
Timer timer)
Create a new
Stream whose values will be only the last value of each batch. |
Stream<O> |
Stream.sampleFirst(int maxSize,
long timespan,
TimeUnit unit,
Timer timer)
Create a new
Stream whose values will be only the first value of each batch. |
Stream<O> |
Stream.sampleFirst(long timespan,
TimeUnit unit,
Timer timer)
Create a new
Stream whose values will be only the first value of each batch. |
Stream<O> |
Stream.skip(long time,
TimeUnit unit,
Timer timer)
Create a new
Stream that will NOT signal next elements up to the specified . |
Stream<O> |
Stream.take(long time,
TimeUnit unit,
Timer timer)
Create a new
Stream that will signal next elements up to the specified . |
Stream<O> |
Stream.throttle(long period,
Timer timer)
Request once the parent stream every milliseconds after an initial .
|
Stream<O> |
Stream.timeout(long timeout,
TimeUnit unit,
org.reactivestreams.Publisher<? extends O> fallback,
Timer timer)
Signal an error if no data has been emitted for milliseconds.
|
static Stream<Long> |
Streams.timer(Timer timer,
long delay)
Build a Stream that will only emit 0l after the time delay and then complete.
|
static Stream<Long> |
Streams.timer(Timer timer,
long delay,
TimeUnit unit)
Build a Stream that will only emit 0l after the time delay and then complete.
|
Stream<Stream<O>> |
Stream.window(int maxSize,
long timespan,
TimeUnit unit,
Timer timer)
Re-route incoming values into a dynamically created
Stream every pre-defined timespan OR maxSize items. |
Stream<Stream<O>> |
Stream.window(long timespan,
long timeshift,
TimeUnit unit,
Timer timer)
Re-route incoming values into bucket streams that will be pushed into the returned
Stream every timeshift period. |
Stream<Stream<O>> |
Stream.window(long timespan,
TimeUnit unit,
Timer timer)
Re-route incoming values into a dynamically created
Stream every pre-defined timespan. |
Modifier and Type | Field and Description |
---|---|
protected Timer |
BatchAction.timer |
Constructor and Description |
---|
BatchAction(Dispatcher dispatcher,
int batchSize,
boolean next,
boolean first,
boolean flush,
long timespan,
TimeUnit unit,
Timer timer) |
BufferAction(Dispatcher dispatcher,
int maxSize,
long timespan,
TimeUnit unit,
Timer timer) |
BufferShiftAction(Dispatcher dispatcher,
int size,
int skip,
long timeshift,
long timespan,
TimeUnit unit,
Timer timer) |
SampleAction(Dispatcher dispatcher,
boolean first,
int maxSize,
long timespan,
TimeUnit unit,
Timer timer) |
WindowAction(Environment environment,
Dispatcher dispatcher,
int backlog,
long timespan,
TimeUnit unit,
Timer timer) |
WindowShiftAction(Environment environment,
Dispatcher dispatcher,
int size,
int skip,
long timespan,
long timeshift,
TimeUnit unit,
Timer timer) |
Constructor and Description |
---|
ThrottleRequestAction(Dispatcher dispatcher,
Timer timer,
long period) |
Constructor and Description |
---|
TimeoutAction(Dispatcher dispatcher,
org.reactivestreams.Publisher<? extends T> fallback,
Timer timer,
long timeout) |
Constructor and Description |
---|
SkipUntilTimeout(long time,
TimeUnit unit,
Timer timer) |
TakeUntilTimeout(Dispatcher dispatcher,
long time,
TimeUnit unit,
Timer timer) |
Constructor and Description |
---|
PeriodicTimerStream(long delay,
long period,
TimeUnit unit,
Timer timer) |
SingleTimerStream(long delay,
TimeUnit unit,
Timer timer) |
Copyright © 2016. All rights reserved.