webmaster/signal-cli
1
0
Fork 0
mirror of https://github.com/AsamK/signal-cli synced 2025-08-29 10:30:38 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update client dependencies

Browse source
This commit is contained in:
AsamK 2024-09-08 18:51:56 +02:00
parent b322716215
commit 2b5451f74a
3 changed files with 482 additions and 335 deletions
Download patch file Download diff file Expand all files Collapse all files

811
client/Cargo.lock generated
View file

File diff suppressed because it is too large Load diff

2
client/Cargo.toml
View file

@ -12,7 +12,7 @@ log = "0.4"
serde = "1" serde = "1"
serde_json = "1" serde_json = "1"
tokio = { version = "1", features = ["rt", "macros", "net", "rt-multi-thread"] } tokio = { version = "1", features = ["rt", "macros", "net", "rt-multi-thread"] }
jsonrpsee = { version = "0.21.0", features = [ jsonrpsee = { version = "0.24", features = [
"macros", "macros",
"async-client", "async-client",
"http-client", "http-client",

4
client/src/main.rs
View file

@ -2,7 +2,7 @@ use std::{path::PathBuf, time::Duration};
use clap::Parser; use clap::Parser;
use jsonrpsee::core::client::{Error as RpcError, Subscription, SubscriptionClientT}; use jsonrpsee::core::client::{Error as RpcError, Subscription, SubscriptionClientT};
use serde_json::Value; use serde_json::{Error, Value};
use tokio::{select, time::sleep}; use tokio::{select, time::sleep};
use cli::Cli; use cli::Cli;
@ -500,7 +500,7 @@ async fn connect(cli: Cli) -> Result<Value, RpcError> {
async fn stream_next( async fn stream_next(
timeout: f64, timeout: f64,
stream: &mut Subscription<Value>, stream: &mut Subscription<Value>,
) -> Option<Result<Value, RpcError>> { ) -> Option<Result<Value, Error>> {
if timeout < 0.0 { if timeout < 0.0 {
stream.next().await stream.next().await
} else { } else {