Class ToggleableDoubleArraySubscriber

java.lang.Object

dev.doglog.internal.tunable.entry.ToggleableDoubleArraySubscriber

All Implemented Interfaces:

DoubleArraySubscriber, PubSub, Subscriber, AutoCloseable, Supplier<double[]>

@NullMarked
public class ToggleableDoubleArraySubscriber
extends Object
implements DoubleArraySubscriber

Constructor Summary

Constructors

Constructor	Description
ToggleableDoubleArraySubscriber(DoubleArraySubscriber subscriber, double[] defaultValue, BooleanSupplier useNt)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	exists()
double[]	get()
double[]	get(double[] defaultValue)
TimestampedDoubleArray	getAtomic()
TimestampedDoubleArray	getAtomic(double[] defaultValue)
int	getHandle()
long	getLastChange()
DoubleArrayTopic	getTopic()
boolean	isValid()
TimestampedDoubleArray[]	readQueue()
double[][]	readQueueValues()

Methods inherited from class Object

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

Constructor Details

ToggleableDoubleArraySubscriber

public ToggleableDoubleArraySubscriber(DoubleArraySubscriber subscriber,
 double[] defaultValue,
 BooleanSupplier useNt)

Method Details

getTopic

public DoubleArrayTopic getTopic()

Specified by:

getTopic in interface DoubleArraySubscriber

Specified by:

getTopic in interface PubSub

get

public double[] get()

Specified by:

get in interface DoubleArraySubscriber

Specified by:

get in interface Supplier<double[]>

get

public double[] get(double[] defaultValue)

Specified by:

get in interface DoubleArraySubscriber

getAtomic

public TimestampedDoubleArray getAtomic()

Specified by:

getAtomic in interface DoubleArraySubscriber

getAtomic

public TimestampedDoubleArray getAtomic(double[] defaultValue)

Specified by:

getAtomic in interface DoubleArraySubscriber

readQueue

public TimestampedDoubleArray[] readQueue()

Specified by:

readQueue in interface DoubleArraySubscriber

readQueueValues

public double[][] readQueueValues()

Specified by:

readQueueValues in interface DoubleArraySubscriber

exists

public boolean exists()

Specified by:

exists in interface Subscriber

getLastChange

public long getLastChange()

Specified by:

getLastChange in interface Subscriber

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PubSub

isValid

public boolean isValid()

Specified by:

isValid in interface PubSub

getHandle

public int getHandle()

Specified by:

getHandle in interface PubSub