0.4.7

libnexakotlin/org.nexa.libnexakotlin/JsonRpc

JsonRpc

open class JsonRpc(val name: String, val port: Int, val logName: String = name + ":" + port, val useSSL: Boolean = false, connectTimeoutMs: Long = JsonRpc.CONNECT_TIMEOUT, val accessTimeoutMs: Long = JsonRpc.ACCESS_TIMEOUT)

Open a JsonRpc communications channel with another node.

Throws

IllegalStateException

if it cannot connect

Inheritors

Constructors

constructor(name: String, port: Int, logName: String = name + ":" + port, useSSL: Boolean = false, connectTimeoutMs: Long = JsonRpc.CONNECT_TIMEOUT, accessTimeoutMs: Long = JsonRpc.ACCESS_TIMEOUT)

Types

object Companion

NotificationData

@Serializable

data class NotificationData(val method: String)

data class OutstandingReq(val callback: (String?) -> Unit, val timeoutAt: Long)

@Serializable

data class ResultData(val id: Int, val jsonrpc: String)

Properties

accessTimeoutMs

val accessTimeoutMs: Long

val json: Json

val logName: String

val name: String

var nextAbortCheck: Long

val notifications: MutableMap<String, (String?) -> Unit>

var open: Boolean

val outstanding: MutableMap<Int, JsonRpc.OutstandingReq>

var sock: iTcpSocket

val useSSL: Boolean = false

Functions

abortAllOutstandingRequests

fun abortAllOutstandingRequests()

abortTimedOutRequests

fun abortTimedOutRequests()

fun call(method: String, params: List<Any?>?, response: (String?) -> Unit): Int

fun call(method: String, params: List<Any?>?, timeoutInMs: Int): String?

fun close(reason: String)

fun nextId(): Int

fun <T> parse(method: String, params: List<String>?, serializer: KSerializer<T>, response: (T?) -> Unit)

fun run()

fun start()

fun stop()

fun subscribe(method: String, params: List<Any?>? = null, response: (String?) -> Unit)