-
public interface RelayInterface
-
-
Method Summary
Modifier and Type Method Description abstract Unitpublish(String topic, String message, Relay.Model.IrnParams params, Long id, Function1<Result<Relay.Model.Call.Publish.Acknowledgement>, Unit> onResult)abstract Unitsubscribe(String topic, Long id, Function1<Result<Relay.Model.Call.Subscribe.Acknowledgement>, Unit> onResult)abstract UnitbatchSubscribe(List<String> topics, Long id, Function1<Result<Relay.Model.Call.BatchSubscribe.Acknowledgement>, Unit> onResult)abstract Unitunsubscribe(String topic, String subscriptionId, Long id, Function1<Result<Relay.Model.Call.Unsubscribe.Acknowledgement>, Unit> onResult)abstract BooleangetIsLoggingEnabled()abstract UnitsetIsLoggingEnabled(Boolean isLoggingEnabled)abstract SharedFlow<Relay.Model.Event>getEventsFlow()abstract Flow<Relay.Model.Call.Subscription.Request>getSubscriptionRequest()-
-
Method Detail
-
publish
abstract Unit publish(String topic, String message, Relay.Model.IrnParams params, Long id, Function1<Result<Relay.Model.Call.Publish.Acknowledgement>, Unit> onResult)
-
subscribe
abstract Unit subscribe(String topic, Long id, Function1<Result<Relay.Model.Call.Subscribe.Acknowledgement>, Unit> onResult)
-
batchSubscribe
abstract Unit batchSubscribe(List<String> topics, Long id, Function1<Result<Relay.Model.Call.BatchSubscribe.Acknowledgement>, Unit> onResult)
-
unsubscribe
abstract Unit unsubscribe(String topic, String subscriptionId, Long id, Function1<Result<Relay.Model.Call.Unsubscribe.Acknowledgement>, Unit> onResult)
-
getIsLoggingEnabled
abstract Boolean getIsLoggingEnabled()
-
setIsLoggingEnabled
abstract Unit setIsLoggingEnabled(Boolean isLoggingEnabled)
-
getEventsFlow
abstract SharedFlow<Relay.Model.Event> getEventsFlow()
-
getSubscriptionRequest
abstract Flow<Relay.Model.Call.Subscription.Request> getSubscriptionRequest()
-
-
-
-