Interface EventLoop.EventLoopProcessor

All Known Implementing Classes:
AnimationEventLoopProcessor, TaskEventLoopProcessor
Enclosing interface:
EventLoop

public static interface EventLoop.EventLoopProcessor
Contract to process event loop messages, possibly translating an event into some other type of event or events.
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    canProcess(org.springframework.messaging.Message<?> message)
    Checks if this processor can process an event.
    reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>>
    process(org.springframework.messaging.Message<?> message)
    Process a message and transform it into a new Flux of Message instances.
  • Method Details

    • canProcess

      boolean canProcess(org.springframework.messaging.Message<?> message)
      Checks if this processor can process an event. If this method returns true it's quaranteed that process(Message) is called to resolve translation of a message.
      Parameters:
      message - the message
      Returns:
      true if processor can process an event
    • process

      reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>> process(org.springframework.messaging.Message<?> message)
      Process a message and transform it into a new Flux of Message instances.
      Parameters:
      message - the message to process
      Returns:
      a flux of messages