1package coordinator
 2
 3import (
 4	"testing"
 5
 6	"github.com/stretchr/testify/assert"
 7)
 8
 9func TestBatchQueue(t *testing.T) {
10	bq := BatchQueue{}
11
12	bq.Push(&BatchInfo{
13		batchNum: 0,
14	})
15	bq.Push(&BatchInfo{
16		batchNum: 2,
17	})
18	bq.Push(&BatchInfo{
19		batchNum: 1,
20	})
21
22	assert.Equal(t, uint64(0), bq.Pop().batchNum)
23	assert.Equal(t, uint64(2), bq.Pop().batchNum)
24	assert.Equal(t, uint64(1), bq.Pop().batchNum)
25	assert.Nil(t, bq.Pop())
26}