Top Inners Fields Constructors Methods

reactor.core.scheduler

pack-priv final Class SchedulerState<T>

Class Inheritance

extends Object

java.lang.Object
reactor.core.scheduler.SchedulerState

Imports

java.util.concurrent.ScheduledExecutorService, .ScheduledThreadPoolExecutor, .TimeUnit, reactor.core.publisher.Flux, .FluxSink, .Mono, reactor.util.annotation.Nullable

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static interface	SchedulerState.DisposeAwaiter<T>
pack-priv static class	SchedulerState.DisposeAwaiterRunnable<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final T	currentResource
pack-priv final T	initialResource
pack-priv final Mono<Void>	onDispose

Constructor Summary

Access	Constructor and Description
private	SchedulerState(T initialResource, T currentResource, Mono<Void> onDispose)

Method Summary

Modifier and Type	Method and Description
pack-priv static <T> SchedulerState<T>	init(final T resource)
pack-priv static <T> SchedulerState<T>	transition(T initial, T next, SchedulerState.DisposeAwaiter<T> awaiter)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

currentResource	back to summary
pack-priv final T currentResource

initialResource	back to summary
pack-priv final T initialResource Annotations @Nullable

onDispose	back to summary
pack-priv final Mono<Void> onDispose

Constructor Detail

SchedulerState	back to summary
private SchedulerState(T initialResource, T currentResource, Mono<Void> onDispose)

Method Detail

init	back to summary
pack-priv static <T> SchedulerState<T> init(final T resource)

transition	back to summary
pack-priv static <T> SchedulerState<T> transition(T initial, T next, SchedulerState.DisposeAwaiter<T> awaiter)

reactor.core.scheduler back to summary

pack-priv Interface SchedulerState.DisposeAwaiter<T>

Known Direct Implementers: reactor.core.scheduler.SingleScheduler, reactor.core.scheduler.ThreadPerTaskBoundedElasticScheduler, reactor.core.scheduler.BoundedElasticScheduler, reactor.core.scheduler.DelegateServiceScheduler, reactor.core.scheduler.ParallelScheduler

Method Summary

Modifier and Type	Method and Description
public boolean	await(T resource, long timeout, TimeUnit timeUnit)

Method Detail

await	back to summary
public boolean await(T resource, long timeout, TimeUnit timeUnit) throws InterruptedException

reactor.core.scheduler back to summary

pack-priv Class SchedulerState.DisposeAwaiterRunnable<T>

Class Inheritance

extends Object
implements Runnable

java.lang.Object
reactor.core.scheduler.SchedulerState.DisposeAwaiterRunnable

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final SchedulerState.DisposeAwaiter<T>	awaiter
private final int	awaitMs
pack-priv volatile boolean	cancelled
private final T	initial
private final FluxSink<Void>	sink
pack-priv static final ScheduledExecutorService	TRANSITION_AWAIT_POOL

Constructor Summary

Access	Constructor and Description
pack-priv	DisposeAwaiterRunnable(SchedulerState.DisposeAwaiter<T> awaiter, T initial, FluxSink<Void> sink, int awaitMs)

Method Summary

Modifier and Type	Method and Description
pack-priv static <R> void	awaitInPool(SchedulerState.DisposeAwaiter<R> awaiter, R initial, FluxSink<Void> sink, int awaitMs)
pack-priv void	cancel()
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

awaiter	back to summary
private final SchedulerState.DisposeAwaiter<T> awaiter

awaitMs	back to summary
private final int awaitMs

cancelled	back to summary
pack-priv volatile boolean cancelled

initial	back to summary
private final T initial

sink	back to summary
private final FluxSink<Void> sink

TRANSITION_AWAIT_POOL	back to summary
pack-priv static final ScheduledExecutorService TRANSITION_AWAIT_POOL

Constructor Detail

DisposeAwaiterRunnable	back to summary
pack-priv DisposeAwaiterRunnable(SchedulerState.DisposeAwaiter<T> awaiter, T initial, FluxSink<Void> sink, int awaitMs)

Method Detail

awaitInPool	back to summary
pack-priv static <R> void awaitInPool(SchedulerState.DisposeAwaiter<R> awaiter, R initial, FluxSink<Void> sink, int awaitMs)

cancel	back to summary
pack-priv void cancel()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override