ForwardEndpoint

constructor(coordinator: WaitCoordinator, models: Collection<AggregateModel<*>>, groups: Collection<PartitionOwnership>, clock: Clock = Clock.systemUTC(), observer: Observer = Observer.NONE)