diff --git a/ethers/providers/jsonrpc.nim b/ethers/providers/jsonrpc.nim index 9b2b72a..729bec5 100644 --- a/ethers/providers/jsonrpc.nim +++ b/ethers/providers/jsonrpc.nim @@ -85,7 +85,7 @@ proc new*( client = http subscriptions = JsonRpcSubscriptions.new(http, pollingInterval = pollingInterval) - subscriptions.init() + subscriptions.start() proc awaitClient: Future[RpcClient] {.async:(raises:[JsonRpcProviderError]).} = convertError: diff --git a/ethers/providers/jsonrpc/subscriptions.nim b/ethers/providers/jsonrpc/subscriptions.nim index 1cf6882..a3f0810 100644 --- a/ethers/providers/jsonrpc/subscriptions.nim +++ b/ethers/providers/jsonrpc/subscriptions.nim @@ -22,7 +22,7 @@ type template `or`(a: JsonNode, b: typed): JsonNode = if a.isNil: b else: a -func init*(subscriptions: JsonRpcSubscriptions) = +func start*(subscriptions: JsonRpcSubscriptions) = subscriptions.client.onProcessMessage = proc(client: RpcClient, line: string): Result[bool, string] {.gcsafe, raises: [].} = diff --git a/testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim b/testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim index 4421c26..a402774 100644 --- a/testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim +++ b/testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim @@ -64,7 +64,7 @@ suite "Web socket subscriptions": client = newRpcWebSocketClient() await client.connect("ws://localhost:8545") subscriptions = JsonRpcSubscriptions.new(client) - subscriptions.init() + subscriptions.start() teardown: await subscriptions.close() @@ -82,7 +82,7 @@ suite "HTTP polling subscriptions": await client.connect("http://localhost:8545") subscriptions = JsonRpcSubscriptions.new(client, pollingInterval = 100.millis) - subscriptions.init() + subscriptions.start() teardown: await subscriptions.close()