From 3a019aa68194ebc6f156ad4b7da54dab94d90237 Mon Sep 17 00:00:00 2001
From: Noah Hilverling <noah@hilverling.com>
Date: Tue, 13 Nov 2018 13:22:50 +0100
Subject: [PATCH] Add support for XDel

---
 commands.go      | 11 +++++++++++
 commands_test.go |  6 ++++++
 2 files changed, 17 insertions(+)

diff --git a/commands.go b/commands.go
index 4ef8ccf5..4a2eadcc 100644
--- a/commands.go
+++ b/commands.go
@@ -166,6 +166,7 @@ type Cmdable interface {
 	SUnion(keys ...string) *StringSliceCmd
 	SUnionStore(destination string, keys ...string) *IntCmd
 	XAdd(a *XAddArgs) *StringCmd
+	XDel(stream string, ids ...string) *IntCmd
 	XLen(stream string) *IntCmd
 	XRange(stream, start, stop string) *XMessageSliceCmd
 	XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd
@@ -1339,6 +1340,16 @@ func (c *cmdable) XAdd(a *XAddArgs) *StringCmd {
 	return cmd
 }
 
+func (c *cmdable) XDel(stream string, ids ...string) *IntCmd {
+	args := []interface{}{"xdel", stream}
+	for _, id := range ids {
+		args = append(args, id)
+	}
+	cmd := NewIntCmd(args...)
+	c.process(cmd)
+	return cmd
+}
+
 func (c *cmdable) XLen(stream string) *IntCmd {
 	cmd := NewIntCmd("xlen", stream)
 	c.process(cmd)
diff --git a/commands_test.go b/commands_test.go
index 9e8e2efe..3c573237 100644
--- a/commands_test.go
+++ b/commands_test.go
@@ -3405,6 +3405,12 @@ var _ = Describe("Commands", func() {
 			}))
 		})
 
+		It("should XDel", func() {
+			n, err := client.XDel("stream", "1-0", "2-0", "3-0").Result()
+			Expect(err).NotTo(HaveOccurred())
+			Expect(n).To(Equal(int64(3)))
+		})
+
 		It("should XLen", func() {
 			n, err := client.XLen("stream").Result()
 			Expect(err).NotTo(HaveOccurred())