)
func TestQueueStartsInMessageOrder(t *testing.T) {
- queue := newQueue()
+ queue := newBuildQueue()
queue.AddLeaf(4)
queue.AddLeaf(5)
queue.AddMerge(nodeKey{1, 2})
}
func TestQueueRetriesAFailedMergeAtTheNextMessage(t *testing.T) {
- queue := newQueue()
+ queue := newBuildQueue()
queue.AddMerge(nodeKey{1, 0})
key, ready := queue.Next()