// Copyright 2019 Parity Technologies (UK) Ltd. // // Permission is hereby granted, free of charge, to any // person obtaining a copy of this software and associated // documentation files (the "Software"), to deal in the // Software without restriction, including without // limitation the rights to use, copy, modify, merge, // publish, distribute, sublicense, and/or sell copies of // the Software, and to permit persons to whom the Software // is furnished to do so, subject to the following // conditions: // // The above copyright notice and this permission notice // shall be included in all copies or substantial portions // of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF // ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED // TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A // PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT // SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY // CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR // IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER // DEALINGS IN THE SOFTWARE. use jsonrpsee::{ types::{traits::SubscriptionClient, v2::params::JsonRpcParams}, ws_client::WsClientBuilder, ws_server::{RpcModule, WsServerBuilder}, }; use std::net::SocketAddr; #[tokio::main] async fn main() -> anyhow::Result<()> { env_logger::init(); let addr = run_server().await?; let url = format!("ws://{}", addr); let client = WsClientBuilder::default().build(&url).await?; // Subscription with a single parameter let params = JsonRpcParams::Array(vec![3.into()]); let mut sub_params_one = client.subscribe::>("sub_one_param", params, "unsub_one_param").await?; println!("subscription with one param: {:?}", sub_params_one.next().await); // Subscription with multiple parameters let params = JsonRpcParams::Array(vec![2.into(), 5.into()]); let mut sub_params_two = client.subscribe::("sub_params_two", params, "unsub_params_two").await?; println!("subscription with two params: {:?}", sub_params_two.next().await); Ok(()) } async fn run_server() -> anyhow::Result { const LETTERS: &str = "abcdefghijklmnopqrstuvxyz"; let mut server = WsServerBuilder::default().build("127.0.0.1:0").await?; let mut module = RpcModule::new(()); module .register_subscription("sub_one_param", "unsub_one_param", |params, mut sink, _| { let idx: usize = params.one()?; std::thread::spawn(move || loop { let _ = sink.send(&LETTERS.chars().nth(idx)); std::thread::sleep(std::time::Duration::from_millis(50)); }); Ok(()) }) .unwrap(); module .register_subscription("sub_params_two", "unsub_params_two", |params, mut sink, _| { let (one, two): (usize, usize) = params.parse()?; std::thread::spawn(move || loop { let _ = sink.send(&LETTERS[one..two].to_string()); std::thread::sleep(std::time::Duration::from_millis(100)); }); Ok(()) }) .unwrap(); server.register_module(module).unwrap(); let addr = server.local_addr()?; tokio::spawn(async move { server.start().await }); Ok(addr) }