X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/baf7a940be8927278e3b4b87e7366cebfc16532f..4343ca5fb6cc86eb887951f4fe16063bab29a238:/build_queue_test.go?ds=inline diff --git a/build_queue_test.go b/build_queue_test.go index 078e06a..34a4571 100644 --- a/build_queue_test.go +++ b/build_queue_test.go @@ -14,6 +14,7 @@ func TestQueueStartsInMessageOrder(t *testing.T) { queue.AddMerge(NodeKey{1, 1}) var order []NodeKey + for { key, ready := queue.Next() if !ready { @@ -34,16 +35,19 @@ func TestQueueRetriesAFailedMergeAtTheNextMessage(t *testing.T) { require.True(t, ready) queue.Fail(key) + _, ready = queue.Next() require.False(t, ready) queue.Retry() + key, ready = queue.Next() require.True(t, ready) require.Equal(t, NodeKey{1, 0}, key) queue.Done(key) queue.AddMerge(NodeKey{1, 0}) + _, ready = queue.Next() require.True(t, ready) }