From e76fb4ab2546a6febc361d3b9dc4e76711f47f6b Mon Sep 17 00:00:00 2001 From: antirez Date: Mon, 29 Jan 2018 18:32:38 +0100 Subject: CG: XPENDING should not create consumers and obey to count. --- src/stream.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src/stream.h') diff --git a/src/stream.h b/src/stream.h index 908e9ff72..bd999d77c 100644 --- a/src/stream.h +++ b/src/stream.h @@ -95,6 +95,6 @@ int streamIteratorGetID(streamIterator *si, streamID *id, int64_t *numfields); void streamIteratorGetField(streamIterator *si, unsigned char **fieldptr, unsigned char **valueptr, int64_t *fieldlen, int64_t *valuelen); void streamIteratorStop(streamIterator *si); streamCG *streamLookupCG(stream *s, sds groupname); -streamConsumer *streamLookupConsumer(streamCG *cg, sds name); +streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create); #endif -- cgit v1.2.1