ports/com.group7.policies.fork/LeastFullForkPolicy/LeastFullForkPolicy

LeastFullForkPolicy

constructor(tags: Iterable<OutputTag<Container<*>>> = generateSequence { newDynamicOutputTag { it.walkDownstream().filterIsInstance<Container<*>>().first() } } .asIterable())

Parameters

T

the type of entities being routed

tags

the tags used to identify downstream containers for each destination

Generated by Dokka
© 2026 Copyright