Function TestRPopLPushSingleElement

lists_test.go:372–401

(t *testing.T)

}

func TestRPopLPushSingleElement(t *testing.T) {
	c := getTestConn()
	ctx := context.Background()

	src := []byte("sr")

	c.Do(ctx, "lclear", src)
	if n, err := c.Do(ctx, "rpush", src, 1).Int64(); err != nil {
		t.Fatal(err)
	} else if n != 1 {
		t.Fatal(n)
	}

	ttl := time.Now().Unix() + 300
	if _, err := c.Do(ctx, "lexpireat", src, ttl).Int64(); err != nil {
		t.Log("lexpireat: ", err)
	}

	if v, err := c.Do(ctx, "rpoplpush", src, src).Int64(); err != nil {
		t.Fatal(err)
	} else if v != 1 {
		t.Fatal(v)
	}

	if tl, err := c.Do(ctx, "lttl", src).Int64(); err != nil {
		t.Fatal(err)
	} else if tl == -1 || tl > ttl {
		t.Fatal(tl)
	}
}

func TestTrim(t *testing.T) {
	c := getTestConn()