package com.ctrip.xpipe.service.client.redis;

import com.ctrip.xpipe.api.command.CommandFuture;
import com.ctrip.xpipe.client.redis.AsyncRedisClient;
import org.junit.Test;

import static org.junit.Assert.*;

/**
 * @author Slight
 * <p>
 * Feb 26, 2022 6:14 PM
 */
public class CRedisAsyncClientTest {

    @Test
    public void setKV() throws Throwable {

        AsyncRedisClient client = CRedisAsyncClientFactory.DEFAULT.getOrCreateClient("BBZ_RedisGovUni");
        Object resource = client.select("K");
        CommandFuture<Object> future = client.write(resource, "SET", "K", "K1");
        future.get();
    }
}
@@ -168,16 +168,42 @@
 .Test;%0A%0A
+import java.util.Arrays;%0A%0A
 import s
@@ -617,16 +617,60 @@
 %0A       
+ assertArrayEquals(%22OK%22.getBytes(), (byte%5B%5D)
  future.
@@ -674,16 +674,17 @@
 re.get()
+)
 ;%0A    %7D%0A

add assert to CRedisAsyncClientTest