Function test_has_flushable_work

crates/buzz-acp/src/queue.rs:2658–2693

()

    #[test]
    fn test_has_flushable_work() {
        let mut q = EventQueue::new(DedupMode::Queue);
        let ch = Uuid::new_v4();

        // Empty queue — no flushable work.
        assert!(!q.has_flushable_work());

        q.push(make_queued(ch, "msg"));
        assert!(q.has_flushable_work());

        // Flush — now in-flight, no flushable work.
        let _batch = q.flush_next().expect("flush");
        assert!(!q.has_flushable_work());

        // Complete — no pending events, no flushable work.
        q.mark_complete(ch);
        assert!(!q.has_flushable_work());

        // Requeue with retry_after — throttled, no flushable work.
        q.push(make_queued(ch, "msg2"));
        let batch2 = q.flush_next().expect("flush2");
        q.requeue(batch2);
        q.mark_complete(ch);
        assert!(
            !q.has_flushable_work(),
            "throttled channel should not be flushable"
        );

        // Manually expire the retry_after to simulate time passing.
        q.retry_after
            .insert(ch, Instant::now() - Duration::from_secs(1));
        assert!(
            q.has_flushable_work(),
            "expired throttle should be flushable"
        );
    }

    #[test]
    fn test_requeue_dead_letters_after_max_retries() {