(t *testing.T)
| 25 | } |
| 26 | |
| 27 | func TestQuickReorderQueue_InOrder(t *testing.T) { |
| 28 | q := MakeQuickReorderQueue[string](10, 100*time.Millisecond) |
| 29 | defer q.Close() |
| 30 | |
| 31 | q.QueueItem("session1", 1, "item1") |
| 32 | q.QueueItem("session1", 2, "item2") |
| 33 | q.QueueItem("session1", 3, "item3") |
| 34 | |
| 35 | items := collectItems(q.C(), 3, 500*time.Millisecond) |
| 36 | |
| 37 | if len(items) != 3 { |
| 38 | t.Fatalf("expected 3 items, got %d", len(items)) |
| 39 | } |
| 40 | if items[0] != "item1" || items[1] != "item2" || items[2] != "item3" { |
| 41 | t.Errorf("expected [item1, item2, item3], got %v", items) |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | func TestQuickReorderQueue_OutOfOrder(t *testing.T) { |
| 46 | q := MakeQuickReorderQueue[string](10, 200*time.Millisecond) |
nothing calls this directly
no test coverage detected