GenericJoinPolicy

Adapter that wraps a GenericPolicy to implement the JoinPolicy interface. Allows generic policies to be used for join node source selection.

the type of entities being merged

policy

the GenericPolicy that handles source selection logic

Constructors

context(_: Simulator)
open override fun initialize(sources: List<PullInputChannel<T>>, destination: PullOutputChannel<T>)

Initializes the policy with the source and destination channels. Sets up initial state and event listeners for channel readiness events.

open override fun noneReady(): Boolean

Checks if no source channels are ready.

Called when a source channel is no longer ready (has no data available).

Called when a source channel becomes ready (has data available).

Selects the source channel to pull from.