()
| 982 | |
| 983 | #[test] |
| 984 | fn test_requeue_marks_frames_ready() { |
| 985 | let mut encoder = default_encoder(); |
| 986 | |
| 987 | let block = make_block(B256::ZERO); |
| 988 | encoder.add_block(block).unwrap(); |
| 989 | encoder.step().unwrap(); |
| 990 | |
| 991 | // Force close the channel. |
| 992 | encoder.advance_l1_head(100); |
| 993 | |
| 994 | let sub = encoder.next_submission().unwrap(); |
| 995 | let sub_id = sub.id; |
| 996 | |
| 997 | // Requeue the submission. |
| 998 | encoder.requeue(sub_id); |
| 999 | |
| 1000 | // The frame should be available again. |
| 1001 | let resub = encoder.next_submission(); |
| 1002 | assert!(resub.is_some()); |
| 1003 | } |
| 1004 | |
| 1005 | #[test] |
| 1006 | fn test_step_idle_when_no_blocks() { |
nothing calls this directly
no test coverage detected