Package me.hsgamer.topper.agent.update

Class UpdateAgent<K,V>

java.lang.Object

me.hsgamer.topper.agent.update.UpdateAgent<K,V>

public class UpdateAgent<K,V>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	UpdateAgent.FilterResult

Constructor Summary

Constructors

Constructor	Description
UpdateAgent(DataHolder<K,V> holder, BiConsumer<K,Consumer<ValueWrapper<V>>> updateConsumer)

Method Summary

Modifier and Type	Method	Description
void	bindTo(AgentHolder<K,V> holder)
Runnable	getSetRunnable()
Runnable	getUpdateRunnable(int maxEntryPerCall)
void	setErrorHandler(BiConsumer<K,ValueWrapper<V>> errorHandler)
void	setErrorHandler(BiFunction<K,ValueWrapper<V>,ValueWrapper<V>> errorHandler)
void	setFilter(Function<K,UpdateAgent.FilterResult> filter)
void	setMaxSkips(int maxSkips)

Methods inherited from class java.lang.Object

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

Constructor Details

UpdateAgent

public UpdateAgent(DataHolder<K,V> holder,
 BiConsumer<K,Consumer<ValueWrapper<V>>> updateConsumer)

Method Details

setFilter

public void setFilter(Function<K,UpdateAgent.FilterResult> filter)

setErrorHandler

public void setErrorHandler(BiFunction<K,ValueWrapper<V>,ValueWrapper<V>> errorHandler)

setErrorHandler

public void setErrorHandler(BiConsumer<K,ValueWrapper<V>> errorHandler)

setMaxSkips

public void setMaxSkips(int maxSkips)

getUpdateRunnable

public Runnable getUpdateRunnable(int maxEntryPerCall)

getSetRunnable

public Runnable getSetRunnable()

bindTo

public void bindTo(AgentHolder<K,V> holder)