X-Git-Url: http://git.giacomolli.uk/onechat/blobdiff_plain/a3b9849a54a6cd8a4cc5b1ae03a39aab31322f7b..522d7fd117285e4e4ce3ea5ec9b5a1722521b681:/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) }