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 TypeMethodDescriptionboolean
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 newFlux
ofMessage
instances.
-
Method Details
-
canProcess
boolean canProcess(org.springframework.messaging.Message<?> message) Checks if this processor can process an event. If this method returnstrue
it's quaranteed thatprocess(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 newFlux
ofMessage
instances.- Parameters:
message
- the message to process- Returns:
- a flux of messages
-