Function TestQueueGetTimeout

protocols/cpc/syncer/queue_test.go:46–52

(t *testing.T)

}

func TestQueueGetTimeout(t *testing.T) {
	q := newQueue(100)
	_, err := q.get()
	if err != ErrTimeout {
		t.Error("err must be ErrTimeout")
	}
}