Package gov.nasa.ammos.plandev.contrib.streamline.core

Class CellRefV2

java.lang.Object

gov.nasa.ammos.plandev.contrib.streamline.core.CellRefV2

public final class CellRefV2
extends Object

Utility class for a simplified allocate method.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CellRefV2.Cell<D>
static final record	CellRefV2.CommutativityTestInput<D>

Method Summary

Modifier and Type	Method	Description
static <D extends Dynamics<?, D>, E extends DynamicsEffect<D>> gov.nasa.ammos.plandev.merlin.framework.CellRef<E,CellRefV2.Cell<D>>	allocate(ErrorCatching<Expiring<D>> initialDynamics, gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<E> effectTrait)	Allocate a new resource with an explicitly given effect type and effect trait.
static <D extends Dynamics<?, D>> gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>>	autoEffects()
static <D extends Dynamics<?, D>> gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>>	autoEffects(Predicate<CellRefV2.CommutativityTestInput<ErrorCatching<Expiring<D>>>> commutativityTest)
static <D extends Dynamics<?, D>> gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>>	commutingEffects()
static <D extends Dynamics<?, D>> gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>>	noncommutingEffects()
static <D extends Dynamics<?, D>> gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>>	resolvingConcurrencyBy(BinaryOperator<DynamicsEffect<D>> combineConcurrent)
static <D> Predicate<CellRefV2.CommutativityTestInput<ErrorCatching<Expiring<D>>>>	testing(Predicate<CellRefV2.CommutativityTestInput<D>> test)	Lift a commutativity test from data to dynamics, correctly comparing expiry and error information in the process.

Methods inherited from class java.lang.Object

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

Method Details

allocate

public static <D extends Dynamics<?,
D>,
E extends DynamicsEffect<D>>
gov.nasa.ammos.plandev.merlin.framework.CellRef<E,CellRefV2.Cell<D>> allocate(ErrorCatching<Expiring<D>> initialDynamics,
 gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<E> effectTrait)

Allocate a new resource with an explicitly given effect type and effect trait.

noncommutingEffects

public static <D extends Dynamics<?,
D>>
gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>> noncommutingEffects()

commutingEffects

public static <D extends Dynamics<?,
D>>
gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>> commutingEffects()

autoEffects

public static <D extends Dynamics<?,
D>>
gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>> autoEffects()

autoEffects

public static <D extends Dynamics<?,
D>>
gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>> autoEffects(Predicate<CellRefV2.CommutativityTestInput<ErrorCatching<Expiring<D>>>> commutativityTest)

testing

public static <D>
Predicate<CellRefV2.CommutativityTestInput<ErrorCatching<Expiring<D>>>> testing(Predicate<CellRefV2.CommutativityTestInput<D>> test)

Lift a commutativity test from data to dynamics, correctly comparing expiry and error information in the process.

resolvingConcurrencyBy

public static <D extends Dynamics<?,
D>>
gov.nasa.ammos.plandev.merlin.protocol.model.EffectTrait<DynamicsEffect<D>> resolvingConcurrencyBy(BinaryOperator<DynamicsEffect<D>> combineConcurrent)