From 19ae809458b545bf320122c83a4554e3e434aa0f Mon Sep 17 00:00:00 2001 From: antirez Date: Thu, 19 Apr 2018 16:11:43 +0200 Subject: [PATCH] Streams: XADD, handle signaling of write in different ways. --- src/t_stream.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/t_stream.c b/src/t_stream.c index 5891b774..ad47941a 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -2019,6 +2019,9 @@ void xdelCommand(client *c) { streamParseIDOrReply(c,c->argv[j],&id,0); /* Retval already checked. */ deleted += streamDeleteItem(s,&id); } + signalModifiedKey(c->db,c->argv[1]); + notifyKeyspaceEvent(NOTIFY_STREAM,"xdel",c->argv[1],c->db->id); + server.dirty += deleted; addReplyLongLong(c,deleted); } /* XINFO CONSUMERS key group