mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-17 10:11:03 +00:00
+1
-1
@@ -24,7 +24,7 @@ codec = { package = "parity-scale-codec", version = "3.0.0", default-features =
|
|||||||
scale-info = { version = "2.0.0", features = ["bit-vec"] }
|
scale-info = { version = "2.0.0", features = ["bit-vec"] }
|
||||||
futures = "0.3.13"
|
futures = "0.3.13"
|
||||||
hex = "0.4.3"
|
hex = "0.4.3"
|
||||||
jsonrpsee = { version = "0.10.1", features = ["async-client", "client-ws-transport"] }
|
jsonrpsee = { version = "0.12.0", features = ["async-client", "client-ws-transport"] }
|
||||||
log = "0.4.14"
|
log = "0.4.14"
|
||||||
serde = { version = "1.0.124", features = ["derive"] }
|
serde = { version = "1.0.124", features = ["derive"] }
|
||||||
serde_json = "1.0.64"
|
serde_json = "1.0.64"
|
||||||
|
|||||||
+1
-1
@@ -564,7 +564,7 @@ pub async fn ws_client(url: &str) -> Result<RpcClient, RpcError> {
|
|||||||
let (sender, receiver) = ws_transport(url).await?;
|
let (sender, receiver) = ws_transport(url).await?;
|
||||||
Ok(RpcClientBuilder::default()
|
Ok(RpcClientBuilder::default()
|
||||||
.max_notifs_per_subscription(4096)
|
.max_notifs_per_subscription(4096)
|
||||||
.build(sender, receiver))
|
.build_with_tokio(sender, receiver))
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn ws_transport(url: &str) -> Result<(WsSender, WsReceiver), RpcError> {
|
async fn ws_transport(url: &str) -> Result<(WsSender, WsReceiver), RpcError> {
|
||||||
|
|||||||
Reference in New Issue
Block a user