Package io.deephaven.engine.updategraph

Class OneShotUpdateCombiner

java.lang.Object

io.deephaven.engine.updategraph.OneShotUpdateCombiner

All Implemented Interfaces:

LogOutputAppendable, NotificationQueue.Dependency, UpdateSourceRegistrar, Runnable

public class OneShotUpdateCombiner
extends Object
implements Runnable, UpdateSourceRegistrar

Update source that combines multiple sources. Each registered source is invoked exactly once on the next run() and then automatically de-registered.

Constructor Summary

Constructors

Constructor	Description
OneShotUpdateCombiner(UpdateGraph updateGraph)

Method Summary

Modifier and Type	Method	Description
void	addSource(@NotNull Runnable updateSource)	Add a source to this registrar.
LogOutput	append(@NotNull LogOutput logOutput)
UpdateGraph	getUpdateGraph()
void	removeSource(@NotNull Runnable updateSource)	Remove a source from this registrar.
void	requestRefresh()	Passes through to the update graph associated with the current update context.
void	run()
boolean	satisfied(long step)	Is this ancestor satisfied? Note that this method must be safe to call on any thread.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency

getUpdateGraph

Methods inherited from interface io.deephaven.engine.updategraph.UpdateSourceRegistrar

removeSources

Constructor Details

OneShotUpdateCombiner

public OneShotUpdateCombiner(UpdateGraph updateGraph)

Method Details

run

public void run()

Specified by:

run in interface Runnable

addSource

public void addSource(@NotNull
 @NotNull Runnable updateSource)

Description copied from interface: UpdateSourceRegistrar

Add a source to this registrar.

Specified by:

addSource in interface UpdateSourceRegistrar

Parameters:

updateSource - The table to add

removeSource

public void removeSource(@NotNull
 @NotNull Runnable updateSource)

Description copied from interface: UpdateSourceRegistrar

Remove a source from this registrar.

Specified by:

removeSource in interface UpdateSourceRegistrar

Parameters:

updateSource - The table to remove

requestRefresh

public void requestRefresh()

Passes through to the update graph associated with the current update context.

Specified by:

requestRefresh in interface UpdateSourceRegistrar

satisfied

public boolean satisfied(long step)

Description copied from interface: NotificationQueue.Dependency

Is this ancestor satisfied? Note that this method must be safe to call on any thread.

Specified by:

satisfied in interface NotificationQueue.Dependency

Parameters:

step - The step for which we are testing satisfaction

Returns:

Whether the dependency is satisfied on step (and will not fire subsequent notifications)

getUpdateGraph

public UpdateGraph getUpdateGraph()

Specified by:

getUpdateGraph in interface NotificationQueue.Dependency

Returns:

the update graph that this dependency is a part of

append

public LogOutput append(@NotNull
 @NotNull LogOutput logOutput)

Specified by:

append in interface LogOutputAppendable