From a273ce9578c4fd6e7a04b2f597785d603fefa1fa Mon Sep 17 00:00:00 2001 From: "zhaozhao.zz" Date: Tue, 16 Oct 2018 23:47:27 +0800 Subject: [PATCH] Streams: rewrite empty streams with certain lastid --- src/aof.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/aof.c b/src/aof.c index 7d31183e..9723fc33 100644 --- a/src/aof.c +++ b/src/aof.c @@ -1167,7 +1167,7 @@ int rewriteStreamObject(rio *r, robj *key, robj *o) { if (rioWriteBulkObject(r,key) == 0) return 0; if (rioWriteBulkString(r,"MAXLEN",6) == 0) return 0; if (rioWriteBulkString(r,"0",1) == 0) return 0; - if (rioWriteBulkString(r,"*",1) == 0) return 0; + if (rioWriteBulkStreamID(r,&s->last_id) == 0) return 0; if (rioWriteBulkString(r,"x",1) == 0) return 0; if (rioWriteBulkString(r,"y",1) == 0) return 0; }