From d32911f15675c85d042a09f862c8cf0e2d640ad2 Mon Sep 17 00:00:00 2001
From: jujiyfb <151103583+jujiyfb@users.noreply.github.com>
Date: Wed, 27 Dec 2023 10:38:28 +0800
Subject: [PATCH] Create RedisPipelineCallBack.java

---
 .../callback/RedisPipelineCallBack.java       | 23 +++++++++++++++++++
 1 file changed, 23 insertions(+)
 create mode 100644 austin-handler/src/main/java/com/java3y/austin/stream/callback/RedisPipelineCallBack.java

diff --git a/austin-handler/src/main/java/com/java3y/austin/stream/callback/RedisPipelineCallBack.java b/austin-handler/src/main/java/com/java3y/austin/stream/callback/RedisPipelineCallBack.java
new file mode 100644
index 0000000..3f05bc6
--- /dev/null
+++ b/austin-handler/src/main/java/com/java3y/austin/stream/callback/RedisPipelineCallBack.java
@@ -0,0 +1,23 @@
+package com.java3y.austin.stream.callback;
+
+import io.lettuce.core.RedisFuture;
+import io.lettuce.core.api.async.RedisAsyncCommands;
+
+import java.util.List;
+
+/**
+ * redis pipeline接口定义
+ *
+ * @author 3y
+ */
+public interface RedisPipelineCallBack {
+
+    /**
+     * 具体执行逻辑
+     *
+     * @param redisAsyncCommands
+     * @return
+     */
+    List<RedisFuture<?>> invoke(RedisAsyncCommands redisAsyncCommands);
+
+}