-
- All Implemented Interfaces:
-
app.perawallet.walletconnectv2.foundation.network.RelayInterface
public abstract class BaseRelayClient implements RelayInterface
-
-
Field Summary
Fields Modifier and Type Field Description private RelayServicerelayServiceprivate BooleanisLoggingEnabledprivate final SharedFlow<Relay.Model.Event>eventsFlowprivate final Flow<Relay.Model.Call.Subscription.Request>subscriptionRequest
-
Constructor Summary
Constructors Constructor Description BaseRelayClient()
-
Method Summary
Modifier and Type Method Description final RelayServicegetRelayService()final UnitsetRelayService(RelayService relayService)BooleangetIsLoggingEnabled()UnitsetIsLoggingEnabled(Boolean isLoggingEnabled)SharedFlow<Relay.Model.Event>getEventsFlow()Flow<Relay.Model.Call.Subscription.Request>getSubscriptionRequest()final UnitobserveResults()Unitpublish(String topic, String message, Relay.Model.IrnParams params, Long id, Function1<Result<Relay.Model.Call.Publish.Acknowledgement>, Unit> onResult)Unitsubscribe(String topic, Long id, Function1<Result<Relay.Model.Call.Subscribe.Acknowledgement>, Unit> onResult)UnitbatchSubscribe(List<String> topics, Long id, Function1<Result<Relay.Model.Call.BatchSubscribe.Acknowledgement>, Unit> onResult)Unitunsubscribe(String topic, String subscriptionId, Long id, Function1<Result<Relay.Model.Call.Unsubscribe.Acknowledgement>, Unit> onResult)-
-
Method Detail
-
getRelayService
final RelayService getRelayService()
-
setRelayService
final Unit setRelayService(RelayService relayService)
-
getIsLoggingEnabled
Boolean getIsLoggingEnabled()
-
setIsLoggingEnabled
Unit setIsLoggingEnabled(Boolean isLoggingEnabled)
-
getEventsFlow
SharedFlow<Relay.Model.Event> getEventsFlow()
-
getSubscriptionRequest
Flow<Relay.Model.Call.Subscription.Request> getSubscriptionRequest()
-
observeResults
final Unit observeResults()
-
publish
@ExperimentalCoroutinesApi() Unit publish(String topic, String message, Relay.Model.IrnParams params, Long id, Function1<Result<Relay.Model.Call.Publish.Acknowledgement>, Unit> onResult)
-
subscribe
@ExperimentalCoroutinesApi() Unit subscribe(String topic, Long id, Function1<Result<Relay.Model.Call.Subscribe.Acknowledgement>, Unit> onResult)
-
batchSubscribe
@ExperimentalCoroutinesApi() Unit batchSubscribe(List<String> topics, Long id, Function1<Result<Relay.Model.Call.BatchSubscribe.Acknowledgement>, Unit> onResult)
-
unsubscribe
@ExperimentalCoroutinesApi() Unit unsubscribe(String topic, String subscriptionId, Long id, Function1<Result<Relay.Model.Call.Unsubscribe.Acknowledgement>, Unit> onResult)
-
-
-
-