#[macro_use] mod macros; mod common; cfg_wasm32! { cfg_fluvio_wasm_timer! { use wasm_bindgen_test::{wasm_bindgen_test, wasm_bindgen_test_configure}; wasm_bindgen_test_configure!(run_in_browser); #[wasm_bindgen_test] async fn single_immediate_delay() { common::delay_queue::single_immediate_delay::().await; } #[wasm_bindgen_test] async fn multiple_immediate_delay() { common::delay_queue::multiple_immediate_delay::().await; } #[wasm_bindgen_test] async fn single_short_delay() { common::delay_queue::single_short_delay::().await; } #[wasm_bindgen_test] async fn multi_delay_at_start() { common::delay_queue::multi_delay_at_start::().await; } #[wasm_bindgen_test] async fn insert_in_past_fires_immediately() { common::delay_queue::insert_in_past_fires_immediately::().await; } #[wasm_bindgen_test] async fn remove_entry() { common::delay_queue::remove_entry::().await; } #[wasm_bindgen_test] async fn reset_entry() { common::delay_queue::reset_entry::().await; } #[wasm_bindgen_test] async fn reset_much_later() { common::delay_queue::reset_much_later::().await; } #[wasm_bindgen_test] async fn reset_twice() { common::delay_queue::reset_twice::().await; } #[wasm_bindgen_test] async fn repeatedly_reset_entry_inserted_as_expired() { common::delay_queue::repeatedly_reset_entry_inserted_as_expired::().await; } #[wasm_bindgen_test] async fn remove_expired_item() { common::delay_queue::remove_expired_item::().await; } #[wasm_bindgen_test] async fn remove_at_timer_wheel_threshold() { common::delay_queue::remove_at_timer_wheel_threshold::().await; } #[wasm_bindgen_test] async fn expires_before_last_insert() { common::delay_queue::expires_before_last_insert::().await; } #[wasm_bindgen_test] async fn multi_reset() { common::delay_queue::multi_reset::().await; } #[wasm_bindgen_test] async fn expire_first_key_when_reset_to_expire_earlier() { common::delay_queue::expire_first_key_when_reset_to_expire_earlier::().await; } #[wasm_bindgen_test] async fn expire_second_key_when_reset_to_expire_earlier() { common::delay_queue::expire_second_key_when_reset_to_expire_earlier::().await; } #[wasm_bindgen_test] async fn reset_first_expiring_item_to_expire_later() { common::delay_queue::reset_first_expiring_item_to_expire_later::().await; } #[wasm_bindgen_test] async fn insert_before_first_after_poll() { common::delay_queue::insert_before_first_after_poll::().await; } #[wasm_bindgen_test] async fn insert_after_ready_poll() { common::delay_queue::insert_after_ready_poll::().await; } #[wasm_bindgen_test] async fn reset_later_after_slot_starts() { common::delay_queue::reset_later_after_slot_starts::().await; } #[wasm_bindgen_test] async fn reset_insert_expired() { common::delay_queue::reset_insert_expired::().await; } #[wasm_bindgen_test] async fn reset_earlier_after_slot_starts() { common::delay_queue::reset_earlier_after_slot_starts::().await; } #[wasm_bindgen_test] async fn insert_in_past_after_poll_fires_immediately() { common::delay_queue::insert_in_past_after_poll_fires_immediately::().await; } #[wasm_bindgen_test] async fn delay_queue_poll_expired_when_empty() { common::delay_queue::delay_queue_poll_expired_when_empty::().await; } #[wasm_bindgen_test] async fn compact_expire_empty() { common::delay_queue::compact_expire_empty::().await; } #[wasm_bindgen_test] async fn compact_remove_empty() { common::delay_queue::compact_remove_empty::().await; } #[wasm_bindgen_test] async fn compact_remove_remapped_keys() { common::delay_queue::compact_remove_remapped_keys::().await; } #[wasm_bindgen_test] async fn compact_change_deadline() { common::delay_queue::compact_change_deadline::().await; } #[wasm_bindgen_test] async fn remove_after_compact() { common::delay_queue::remove_after_compact::().await; } // #[wasm_bindgen_test] // #[should_panic] // async fn panic_on_remove_of_nonexistent_key() { // common::delay_queue::panic_on_remove_of_nonexistent_key::().await; // } // #[wasm_bindgen_test] // #[should_panic] // async fn panic_on_remove_after_compact_poll() { // common::delay_queue::panic_on_remove_after_compact_poll::().await; // } } }