logos-storage/nim-ethers
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-ethers.git synced 2026-01-09 09:03:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename subscriptions.init > subscriptions.start

Browse Source
This commit is contained in:
Eric 2024-02-19 16:33:35 +11:00
parent fc2ffff279
commit 0ad648efdd
No known key found for this signature in database
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ethers/providers/jsonrpc.nim
View File

@ -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:

2
ethers/providers/jsonrpc/subscriptions.nim
View File

@ -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: [].} =

4
testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim
View File

@ -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()