From 0ad648efdd6835a404eaf338e4cb9ba1ad1f8730 Mon Sep 17 00:00:00 2001 From: Eric <5089238+emizzle@users.noreply.github.com> Date: Mon, 19 Feb 2024 16:33:35 +1100 Subject: [PATCH] rename subscriptions.init > subscriptions.start --- ethers/providers/jsonrpc.nim | 2 +- ethers/providers/jsonrpc/subscriptions.nim | 2 +- testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) 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()