Object PulsarEventBus
-
- All Implemented Interfaces:
public class PulsarEventBusThe global EventBus for handling events.
-
-
Field Summary
Fields Modifier and Type Field Description private PageEventHandlerspageEventHandlersprivate ServerSideEventHandlersserverSideEventHandlerspublic final static PulsarEventBusINSTANCE
-
Method Summary
Modifier and Type Method Description final <T extends Any> TwithServerSideEventHandlers(ServerSideEventHandlers handlers, SuspendFunction0<T> block)Runs block with handlers bound to the current coroutine execution context. final UnitemitCrawlEvent(String eventType, String url, String message)Emits a browser event to server-side event handlers in a non-blocking manner. final UnitemitLoadEvent(String eventType, WebPage page, String message, Map<String, Object> metadata)Emits a load event to server-side event handlers in a non-blocking manner. final UnitemitBrowseEvent(String eventType, WebPage page, String message, Map<String, Object> metadata)Emits a browse event to server-side event handlers in a non-blocking manner. final PageEventHandlersgetPageEventHandlers()The page event handlers. final UnitsetPageEventHandlers(PageEventHandlers pageEventHandlers)The page event handlers. final ServerSideEventHandlersgetServerSideEventHandlers()The server-side event handlers for broadcasting events to external listeners. final UnitsetServerSideEventHandlers(ServerSideEventHandlers serverSideEventHandlers)The server-side event handlers for broadcasting events to external listeners. -
-
Method Detail
-
withServerSideEventHandlers
final <T extends Any> T withServerSideEventHandlers(ServerSideEventHandlers handlers, SuspendFunction0<T> block)
-
emitCrawlEvent
final Unit emitCrawlEvent(String eventType, String url, String message)
Emits a browser event to server-side event handlers in a non-blocking manner. This method can be called from any thread without blocking.
-
emitLoadEvent
final Unit emitLoadEvent(String eventType, WebPage page, String message, Map<String, Object> metadata)
Emits a load event to server-side event handlers in a non-blocking manner. This method can be called from any thread without blocking.
-
emitBrowseEvent
final Unit emitBrowseEvent(String eventType, WebPage page, String message, Map<String, Object> metadata)
Emits a browse event to server-side event handlers in a non-blocking manner. This method can be called from any thread without blocking.
-
getPageEventHandlers
final PageEventHandlers getPageEventHandlers()
The page event handlers.
The calling order rule:
The more specific handlers has the opportunity to override the result of more general handlers.
-
setPageEventHandlers
final Unit setPageEventHandlers(PageEventHandlers pageEventHandlers)
The page event handlers.
The calling order rule:
The more specific handlers has the opportunity to override the result of more general handlers.
-
getServerSideEventHandlers
final ServerSideEventHandlers getServerSideEventHandlers()
The server-side event handlers for broadcasting events to external listeners.
NOTE: kept for backward compatibility as the default handlers.
-
setServerSideEventHandlers
final Unit setServerSideEventHandlers(ServerSideEventHandlers serverSideEventHandlers)
The server-side event handlers for broadcasting events to external listeners.
NOTE: kept for backward compatibility as the default handlers.
-
-
-
-