ports/com.group7.policies.join/JoinPolicy

JoinPolicy

Policy for selecting sources in a join node (many-to-one merging). Determines which source channel provides the next entity when the destination pulls.

Parameters

the type of entities being merged

Inheritors

MostFullJoinPolicy

GenericJoinPolicy

Functions

initialize

context(_: Simulator)
open 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.

noneReady

abstract fun noneReady(): Boolean

Checks if no source channels are ready.

onChannelNotReady

abstract fun onChannelNotReady(channel: PullInputChannel<T>)

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

onChannelReady

abstract fun onChannelReady(channel: PullInputChannel<T>)

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

selectChannel

abstract fun selectChannel(): PullInputChannel<T>

Selects the source channel to pull from.