Function enqueue_and_poll_ready

nodedb-crdt/src/deferred.rs:193–220

()

    #[test]
    fn enqueue_and_poll_ready() {
        let mut queue = DeferredQueue::new(10);
        let now = 1000;

        // Enqueue an entry ready to retry at now + 500ms
        queue.enqueue(
            42,
            0,
            0,
            b"delta".to_vec(),
            "posts".to_string(),
            "posts_author_fk".to_string(),
            0,
            3,
            now,
            500,
            60,
        );

        // At time=now, entry is not ready
        assert!(queue.poll_ready(now).is_empty());

        // At time=now+500, entry is ready
        let ready = queue.poll_ready(now + 500);
        assert_eq!(ready.len(), 1);
        assert_eq!(ready[0].attempt, 0);
        assert!(queue.is_empty());
    }

    #[test]
    fn expire_past_ttl() {