Akka FSM matchEvent implemantation

Question

Я пытаюсь понять AKKA FSM "matchEvent":

public final <ET> FSMStateFunctionBuilder<S, D> matchEvent(Class<ET> eventType, TypedPredicate2<ET, D> predicate, Apply2<ET, D, State<S, D>> apply) { 
     return (new FSMStateFunctionBuilder()).event(eventType, predicate, apply); 
    } 

после просмотра в http://doc.akka.io/japi/akka/2.3.4/index.html?akka/actor/AbstractFSM.html это то, что я нашел:

public <P> FSMStateFunctionBuilder<S,D> event(java.lang.Class<P> eventType, 
               FI.TypedPredicate2<P,D> predicate, 
               FI.Apply2<P,D,FSM.State<S,D>> apply) 

Добавить тематическое заявление, соответствует типу события и предикату . Параметры: eventType - тип события для соответствия по предикату - предикат, который будет оцениваться по данным и действию события - действие для применения к данным события и состояния, если есть соответствие Возвраты: строитель со случаем заявление добавлено

Может ли кто-нибудь сказать мне, как осуществляется реализация событий?

Answer 1

Выдержки из документации simple example:

... 
public class Buncher extends AbstractFSM<State, Data> { 
{ 
    startWith(Idle, Uninitialized); 

    when(Idle, 
    matchEvent(SetTarget.class, Uninitialized.class, 
     (setTarget, uninitialized) -> 
     stay().using(new Todo(setTarget.getRef(), new LinkedList<>())))); 

    // transition elided ... 

    when(Active, Duration.create(1, "second"), 
    matchEvent(Arrays.asList(Flush.class, StateTimeout()), Todo.class, 
     (event, todo) -> goTo(Idle).using(todo.copy(new LinkedList<>())))); 

    // unhandled elided ... 

    initialize(); 
    } 
} 

Answer 2

В случае, если вы хотите, чтобы выразить состояние охраны на основе входящего поля событий или данных (или их комбинации), использовать что-то вроде ...:

when(Active, Duration.create(1, "second"), 
    matchEvent(Arrays.asList(Flush.class, StateTimeout()), Todo.class, 
     (event, todo) -> todo.getQueue != null //any logical condition using event or data, 

     (event, todo) -> goTo(Idle).using(todo.copy(new LinkedList<>()))));