Interface AsyncTriggerConverter


  • @Internal
    public interface AsyncTriggerConverter
    A converter from Trigger to AsyncTrigger.

    Basic triggers (e.g., CountTrigger) are directly converted to their async version.

    Async-support triggers which implement AsyncTriggerConvertable (e.g., ProcessingTimeoutTrigger) will use self-defined async version.

    Other triggers are wrapped as an AsyncTrigger, whose internal functions are executed in sync mode.

    • Method Detail

      • convertToAsync

        @Nonnull
        default Object convertToAsync()
        Convert to an AsyncTrigger. The default implementation is only a wrapper of the trigger, whose behaviours are all sync.

        TODO: Return AsyncTrigger if AsyncTrigger becomes @PublicEvolving.

        Returns:
        The AsyncTrigger for async state processing.