com.conveyal.r5.otp2.rangeraptor.workerlifecycle

Class LifeCycleBuilder

java.lang.Object

com.conveyal.r5.otp2.rangeraptor.workerlifecycle.LifeCycleBuilder

All Implemented Interfaces:

WorkerLifeCycle

public final class LifeCycleBuilder
extends Object
implements WorkerLifeCycle

The responsibility of this class is to provide an interface for Range Raptor workerlifecycle event listeners to subscribe for such events.

Constructor Summary

Constructors

Constructor and Description
LifeCycleBuilder()

Method Summary

Modifier and Type	Method and Description
void	onIterationComplete(Runnable iterationComplete) Subscribe to 'iteration complete' events by register listener.
void	onPrepareForNextRound(Runnable prepareForNextRound) Subscribe to 'prepare for next round' events by register listener.
void	onRoundComplete(Consumer<Boolean> roundCompleteWithDestinationReached) Subscribe to 'round complete' events by register a boolean consumer.
void	onSetupIteration(IntConsumer setupIterationWithDepartureTime) Subscribe to 'setup iteration' events by register a int consumer.
void	onTransfersForRoundComplete(Runnable transfersForRoundComplete) Subscribe to 'transfers for round complete' events by register listener.
void	onTransitsForRoundComplete(Runnable transitsForRoundComplete) Subscribe to 'transits for round complete' events by register listener.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LifeCycleBuilder

public LifeCycleBuilder()

Method Detail

onSetupIteration

public void onSetupIteration(IntConsumer setupIterationWithDepartureTime)

Description copied from interface: WorkerLifeCycle

Subscribe to 'setup iteration' events by register a int consumer. Every time an iteration start the listener(the input parameter) is notified with the iterationDepartureTime passed in as an argument.

Specified by:

onSetupIteration in interface WorkerLifeCycle

Parameters:

setupIterationWithDepartureTime - if null nothing is added to the publisher.

onPrepareForNextRound

public void onPrepareForNextRound(Runnable prepareForNextRound)

Description copied from interface: WorkerLifeCycle

Subscribe to 'prepare for next round' events by register listener. Every time a new round start the listener(the input parameter) is notified/invoked.

Specified by:

onPrepareForNextRound in interface WorkerLifeCycle

Parameters:

prepareForNextRound - if null nothing is added to the publisher.

onTransitsForRoundComplete

public void onTransitsForRoundComplete(Runnable transitsForRoundComplete)

Description copied from interface: WorkerLifeCycle

Subscribe to 'transits for round complete' events by register listener. This event occur when the transit calculation in each round is finished/complete and the registered listener(the input parameter) is notified/invoked.

Specified by:

onTransitsForRoundComplete in interface WorkerLifeCycle

Parameters:

transitsForRoundComplete - if null nothing is added to the publisher.

onTransfersForRoundComplete

public void onTransfersForRoundComplete(Runnable transfersForRoundComplete)

Description copied from interface: WorkerLifeCycle

Subscribe to 'transfers for round complete' events by register listener. This event occur when the all transfers are calculated in each round. The registered listener(the input parameter) is notified/invoked when this happens.

Specified by:

onTransfersForRoundComplete in interface WorkerLifeCycle

Parameters:

transfersForRoundComplete - if null nothing is added to the publisher.

onRoundComplete

public void onRoundComplete(Consumer<Boolean> roundCompleteWithDestinationReached)

Description copied from interface: WorkerLifeCycle

Subscribe to 'round complete' events by register a boolean consumer. Every time a round finish the listener(the input parameter) is notified with a flag indicating if the destination is reached in the current round.

Specified by:

onRoundComplete in interface WorkerLifeCycle

Parameters:

roundCompleteWithDestinationReached - if null nothing is added to the publisher.

onIterationComplete

public void onIterationComplete(Runnable iterationComplete)

Description copied from interface: WorkerLifeCycle

Subscribe to 'iteration complete' events by register listener. Every time an iteration finish/completes the listener(the input parameter) is notified/invoked.

Specified by:

onIterationComplete in interface WorkerLifeCycle

Parameters:

iterationComplete - if null nothing is added to the publisher.