Method Detail

• observeWebSocketEvent

  @Receive() abstract Flow<WebSocket.Event> observeWebSocketEvent()

• publishRequest

  @Send() abstract Unit publishRequest(RelayDTO.Publish.Request publishRequest)

• observePublishAcknowledgement

  @Receive() abstract Flow<RelayDTO.Publish.Result.Acknowledgement> observePublishAcknowledgement()

• observePublishError

  @Receive() abstract Flow<RelayDTO.Publish.Result.JsonRpcError> observePublishError()

• subscribeRequest

  @Send() abstract Unit subscribeRequest(RelayDTO.Subscribe.Request subscribeRequest)

• observeSubscribeAcknowledgement

  @Receive() abstract Flow<RelayDTO.Subscribe.Result.Acknowledgement> observeSubscribeAcknowledgement()

• observeSubscribeError

  @Receive() abstract Flow<RelayDTO.Subscribe.Result.JsonRpcError> observeSubscribeError()

• batchSubscribeRequest

  @Send() abstract Unit batchSubscribeRequest(RelayDTO.BatchSubscribe.Request subscribeRequest)

• observeBatchSubscribeAcknowledgement

  @Receive() abstract Flow<RelayDTO.BatchSubscribe.Result.Acknowledgement> observeBatchSubscribeAcknowledgement()

• observeBatchSubscribeError

  @Receive() abstract Flow<RelayDTO.BatchSubscribe.Result.JsonRpcError> observeBatchSubscribeError()

• observeSubscriptionRequest

  @Receive() abstract Flow<RelayDTO.Subscription.Request> observeSubscriptionRequest()

• publishSubscriptionAcknowledgement

  @Send() abstract Unit publishSubscriptionAcknowledgement(RelayDTO.Subscription.Result.Acknowledgement publishRequest)

• unsubscribeRequest

  @Send() abstract Unit unsubscribeRequest(RelayDTO.Unsubscribe.Request unsubscribeRequest)

• observeUnsubscribeAcknowledgement

  @Receive() abstract Flow<RelayDTO.Unsubscribe.Result.Acknowledgement> observeUnsubscribeAcknowledgement()

• observeUnsubscribeError

  @Receive() abstract Flow<RelayDTO.Unsubscribe.Result.JsonRpcError> observeUnsubscribeError()