io.spine.server.delivery

Interface CatchUpProcess.DispatchCatchingUp<I>

Type Parameters:

I - the type of the identifiers of the entities to which the event should be dispatched.

Enclosing class:

CatchUpProcess<I>

@FunctionalInterface
public static interface CatchUpProcess.DispatchCatchingUp<I>

A method object dispatching the event to catch-up.

Method Summary

Modifier and Type	Method and Description
java.util.Set<I>	perform(ProjectionRepository<I,?,?> repo, io.spine.core.Event event, @Nullable java.util.Set<I> narrowDownToIds) Dispatches the given event and optionally narrowing down the entities by the set of entity identifiers to dispatch the event to.

Method Detail

perform

java.util.Set<I> perform(ProjectionRepository<I,?,?> repo,
                         io.spine.core.Event event,
                         @Nullable java.util.Set<I> narrowDownToIds)

Dispatches the given event and optionally narrowing down the entities by the set of entity identifiers to dispatch the event to.

If no particular IDs are specified, the event will be dispatched according to the repository routing rules.

Parameters:

repo - the projection repository which manages the entities involved into the catch-up

event - event to dispatch

narrowDownToIds - optional set of identifiers of the targets to narrow down the event targets

Returns:

the set of identifiers to which the event was actually dispatched