Package com.vaadin.hilla.signals.handler

Class SignalsHandler

java.lang.Object

com.vaadin.hilla.signals.handler.SignalsHandler

public class SignalsHandler
extends Object

Handler Endpoint for Fullstack Signals' subscription and update events.

Constructor Summary

Constructors

Constructor	Description
SignalsHandler(SecureSignalsRegistry registry)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<com.fasterxml.jackson.databind.node.ObjectNode>	subscribe(String providerEndpoint, String providerMethod, String clientSignalId, com.fasterxml.jackson.databind.node.ObjectNode body, String parentClientSignalId)	Subscribes to a signal.
void	update(String clientSignalId, com.fasterxml.jackson.databind.node.ObjectNode event)	Updates a signal with an event.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SignalsHandler

public SignalsHandler(@Nullable
 SecureSignalsRegistry registry)

Method Details

subscribe

public reactor.core.publisher.Flux<com.fasterxml.jackson.databind.node.ObjectNode> subscribe(String providerEndpoint,
 String providerMethod,
 String clientSignalId,
 com.fasterxml.jackson.databind.node.ObjectNode body,
 @Nullable
 String parentClientSignalId)

Subscribes to a signal.

Parameters:

providerEndpoint - the endpoint that provides the signal

providerMethod - the endpoint method that provides the signal

clientSignalId - the client signal id

Returns:

a Flux of JSON events

update

public void update(String clientSignalId,
 com.fasterxml.jackson.databind.node.ObjectNode event)
            throws EndpointInvocationException.EndpointAccessDeniedException,
EndpointInvocationException.EndpointNotFoundException

Updates a signal with an event.

Parameters:

clientSignalId - the clientSignalId associated with the signal to update

event - the event to update with

Throws:

EndpointInvocationException.EndpointAccessDeniedException

EndpointInvocationException.EndpointNotFoundException