[bfops/wasm-test]: remove unused

Author: bfops

sdks/rust/tests/test-client/src/main.rs

@@ -2488,119 +2488,6 @@ async fn exec_row_deduplication_r_join_s_and_r_join_t() {
     assert_eq!(count_unique_u32_on_insert.load(Ordering::SeqCst), 1);
 }
 
-#[cfg(all(target_arch = "wasm32", feature = "web"))]
-async fn exec_row_deduplication_r_join_s_and_r_join_t_async() {
-    use gloo_timers::future::TimeoutFuture;
-
-    let on_subscription_applied = Arc::new(AtomicBool::new(false));
-    let pk_u32_on_insert = Arc::new(AtomicBool::new(false));
-    let pk_u32_on_delete = Arc::new(AtomicBool::new(false));
-    let pk_u32_two_on_insert = Arc::new(AtomicBool::new(false));
-    let count_unique_u32_on_insert = Arc::new(AtomicUsize::new(0));
-
-    let name = db_name_or_panic();
-    let builder = DbConnection::builder()
-        .with_database_name(name)
-        .with_uri(LOCALHOST)
-        .on_connect({
-            let on_subscription_applied = on_subscription_applied.clone();
-            let pk_u32_on_insert = pk_u32_on_insert.clone();
-            let pk_u32_on_delete = pk_u32_on_delete.clone();
-            let pk_u32_two_on_insert = pk_u32_two_on_insert.clone();
-            let count_unique_u32_on_insert = count_unique_u32_on_insert.clone();
-
-            move |ctx, _, _| {
-                let queries = [
-                    "SELECT * FROM pk_u_32;",
-                    "SELECT * FROM pk_u_32_two;",
-                    "SELECT unique_u_32.* FROM unique_u_32 JOIN pk_u_32 ON unique_u_32.n = pk_u_32.n;",
-                    "SELECT unique_u_32.* FROM unique_u_32 JOIN pk_u_32_two ON unique_u_32.n = pk_u_32_two.n;",
-                ];
-
-                const KEY: u32 = 42;
-                const DATA: i32 = 0xbeef;
-
-                UniqueU32::insert(ctx, KEY, DATA);
-
-                subscribe_these_then(ctx, &queries, {
-                    let on_subscription_applied = on_subscription_applied.clone();
-                    move |ctx| {
-                        PkU32::insert(ctx, KEY, DATA);
-                        assert_all_tables_empty(ctx).unwrap();
-                        on_subscription_applied.store(true, Ordering::SeqCst);
-                    }
-                });
-                PkU32::on_insert(ctx, {
-                    let pk_u32_on_insert = pk_u32_on_insert.clone();
-                    move |ctx, val| {
-                        assert_eq!(val, &PkU32 { n: KEY, data: DATA });
-                        pk_u32_on_insert.store(true, Ordering::SeqCst);
-                        ctx.reducers
-                            .delete_pk_u_32_insert_pk_u_32_two_then(
-                                KEY,
-                                DATA,
-                                reducer_callback_assert_committed("delete_pk_u_32_insert_pk_u_32_two"),
-                            )
-                            .unwrap();
-                    }
-                });
-                PkU32Two::on_insert(ctx, {
-                    let pk_u32_two_on_insert = pk_u32_two_on_insert.clone();
-                    move |_, val| {
-                        assert_eq!(val, &PkU32Two { n: KEY, data: DATA });
-                        pk_u32_two_on_insert.store(true, Ordering::SeqCst);
-                    }
-                });
-                PkU32::on_delete(ctx, {
-                    let pk_u32_on_delete = pk_u32_on_delete.clone();
-                    move |_, val| {
-                        assert_eq!(val, &PkU32 { n: KEY, data: DATA });
-                        pk_u32_on_delete.store(true, Ordering::SeqCst);
-                    }
-                });
-                UniqueU32::on_insert(ctx, {
-                    let count_unique_u32_on_insert = count_unique_u32_on_insert.clone();
-                    move |_, _| {
-                        count_unique_u32_on_insert.fetch_add(1, Ordering::SeqCst);
-                    }
-                });
-                UniqueU32::on_delete(ctx, move |_, _| panic!());
-                PkU32Two::on_delete(ctx, move |_, _| panic!());
-            }
-        })
-        .on_connect_error(|_ctx, error| panic!("Connect errored: {error:?}"));
-
-    let conn = ManagedConnection::new(builder.build().await.unwrap());
-    conn.run_background_task();
-
-    const WAIT_INTERVAL_MS: u32 = 10;
-    const MAX_WAIT_ITERATIONS: u32 = 3000;
-    let all_callbacks_observed = || {
-        on_subscription_applied.load(Ordering::SeqCst)
-            && pk_u32_on_insert.load(Ordering::SeqCst)
-            && pk_u32_on_delete.load(Ordering::SeqCst)
-            && pk_u32_two_on_insert.load(Ordering::SeqCst)
-    };
-    for _ in 0..MAX_WAIT_ITERATIONS {
-        if all_callbacks_observed() {
-            break;
-        }
-        TimeoutFuture::new(WAIT_INTERVAL_MS).await;
-    }
-    if !all_callbacks_observed() {
-        panic!(
-            "Timeout waiting for callbacks: on_subscription_applied={}, pk_u32_on_insert={}, pk_u32_on_delete={}, pk_u32_two_on_insert={}",
-            on_subscription_applied.load(Ordering::SeqCst),
-            pk_u32_on_insert.load(Ordering::SeqCst),
-            pk_u32_on_delete.load(Ordering::SeqCst),
-            pk_u32_two_on_insert.load(Ordering::SeqCst),
-        );
-    }
-
-    assert_eq!(count_unique_u32_on_insert.load(Ordering::SeqCst), 1);
-    conn.disconnect().unwrap();
-}
-
 /// This test asserts that the correct callbacks are invoked when updating the lhs table of a join
 async fn test_lhs_join_update() {
     let insert_counter = TestCounter::new();