GenericForkPolicy

Adapter that wraps a GenericPolicy to implement the ForkPolicy interface. Allows generic policies to be used for fork node routing.

the type of entities being routed

policy

the GenericPolicy that handles channel selection logic

Constructors

open override fun allClosed(): Boolean

Checks if all destination channels are closed.

context(_: Simulator)
open override fun initialize(source: PushInputChannel<T>, destinations: List<PushOutputChannel<T>>)

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

Called when a destination channel closes.

Called when a destination channel opens.

Selects the destination channel for an entity.