package com.cmvr.test.flow.runtime.interceptor;

import com.cmvr.test.flow.runtime.message.TaskNodeExecuteMessage;
import com.cmvr.test.flow.runtime.message.TaskNodeExecuteResult;

import java.util.function.Function;

/**
 * 流程消息前置处理
 */
public interface FlowMsgPreInterceptor {

    /**
     * 拦截任务节点执行消息
     * @param message 原始执行消息
     * @param next 下一个处理函数
     * @return 返回最终执行结果
     */
    TaskNodeExecuteResult intercept(TaskNodeExecuteMessage message,
                                    Function<TaskNodeExecuteMessage, TaskNodeExecuteResult> next);
}
