Method Detail

• checkConnectionWorking

   abstract Unit checkConnectionWorking()

• subscribe

   abstract Unit subscribe(Topic topic, Function1<Topic, Unit> onSuccess, Function1<Throwable, Unit> onFailure)

• batchSubscribe

   abstract Unit batchSubscribe(List<String> topics, Function1<List<String>, Unit> onSuccess, Function1<Throwable, Unit> onFailure)

• unsubscribe

   abstract Unit unsubscribe(Topic topic, Function0<Unit> onSuccess, Function1<Throwable, Unit> onFailure)

• publishJsonRpcRequest

   abstract Unit publishJsonRpcRequest(Topic topic, IrnParams params, JsonRpcClientSync<?> payload, EnvelopeType envelopeType, Participants participants, Function0<Unit> onSuccess, Function1<Throwable, Unit> onFailure)

• publishJsonRpcResponse

   abstract Unit publishJsonRpcResponse(Topic topic, IrnParams params, JsonRpcResponse response, Function0<Unit> onSuccess, Function1<Throwable, Unit> onFailure, Participants participants, EnvelopeType envelopeType)

• respondWithParams

   abstract Unit respondWithParams(WCRequest request, ClientParams clientParams, IrnParams irnParams, EnvelopeType envelopeType, Participants participants, Function1<Throwable, Unit> onFailure, Function0<Unit> onSuccess)

• respondWithParams

   abstract Unit respondWithParams(Long requestId, Topic topic, ClientParams clientParams, IrnParams irnParams, EnvelopeType envelopeType, Participants participants, Function1<Throwable, Unit> onFailure, Function0<Unit> onSuccess)

• respondWithSuccess

   abstract Unit respondWithSuccess(WCRequest request, IrnParams irnParams, EnvelopeType envelopeType, Participants participants)

• respondWithError

   abstract Unit respondWithError(WCRequest request, Error error, IrnParams irnParams, EnvelopeType envelopeType, Participants participants, Function1<WCRequest, Unit> onSuccess, Function1<Throwable, Unit> onFailure)

• respondWithError

   abstract Unit respondWithError(Long requestId, Topic topic, Error error, IrnParams irnParams, EnvelopeType envelopeType, Participants participants, Function0<Unit> onSuccess, Function1<Throwable, Unit> onFailure)

• getWssConnectionState

   abstract StateFlow<WSSConnectionState> getWssConnectionState()

• getClientSyncJsonRpc

   abstract SharedFlow<WCRequest> getClientSyncJsonRpc()

• getPeerResponse

   abstract SharedFlow<WCResponse> getPeerResponse()

• getInternalErrors

   abstract SharedFlow<SDKError> getInternalErrors()