fix: nits in tests (#1750)

* fix: nits in tests

* fix filter nit

subxt/src/backend/rpc/reconnecting_rpc_client/tests.rs

@@ -13,7 +13,6 @@ use jsonrpsee::server::{
 
 #[tokio::test]
 async fn call_works() {
-    tracing_subscriber::fmt::init();
     let (_handle, addr) = run_server().await.unwrap();
     let client = RpcClient::builder().build(addr).await.unwrap();
     assert!(client.request("say_hello".to_string(), None).await.is_ok(),)
@@ -21,7 +20,6 @@ async fn call_works() {
 
 #[tokio::test]
 async fn sub_works() {
-    tracing_subscriber::fmt::init();
     let (_handle, addr) = run_server().await.unwrap();
 
     let client = RpcClient::builder()
@@ -44,7 +42,6 @@ async fn sub_works() {
 
 #[tokio::test]
 async fn sub_with_reconnect() {
-    tracing_subscriber::fmt::init();
     let (handle, addr) = run_server().await.unwrap();
     let client = RpcClient::builder().build(addr.clone()).await.unwrap();
 
@@ -89,7 +86,6 @@ async fn sub_with_reconnect() {
 
 #[tokio::test]
 async fn call_with_reconnect() {
-    tracing_subscriber::fmt::init();
     let (handle, addr) = run_server_with_settings(None, true).await.unwrap();
 
     let client = Arc::new(RpcClient::builder().build(addr.clone()).await.unwrap());

testing/integration-tests/src/full_client/client/mod.rs

@@ -415,7 +415,6 @@ async fn partial_fee_estimate_correct() {
 #[subxt_test]
 async fn legacy_and_unstable_block_subscription_reconnect() {
     let ctx = test_context_reconnecting_rpc_client().await;
-
     let api = ctx.unstable_client().await;
 
     let unstable_client_blocks = move |num: usize| {
@@ -425,6 +424,16 @@ async fn legacy_and_unstable_block_subscription_reconnect() {
                 .subscribe_finalized()
                 .await
                 .unwrap()
+                // Ignore `disconnected events`.
+                // This will be emitted by the legacy backend for every reconnection.
+                .filter(|item| {
+                    let disconnected = match item {
+                        Ok(_) => false,
+                        Err(e) => e.is_disconnected_will_reconnect(),
+                    };
+
+                    futures::future::ready(!disconnected)
+                })
                 .take(num)
                 .map(|x| x.unwrap().hash().to_string())
                 .collect::<Vec<String>>()