diff options
| author | antirez <antirez@gmail.com> | 2018-01-29 18:32:38 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
| commit | e76fb4ab2546a6febc361d3b9dc4e76711f47f6b (patch) | |
| tree | b72cb9d84ae33373def22410b0fd1119289ac066 /src/stream.h | |
| parent | f3708af7f9ea6b3a097d2b33ee7c28624b753215 (diff) | |
| download | redis-e76fb4ab2546a6febc361d3b9dc4e76711f47f6b.tar.gz | |
CG: XPENDING should not create consumers and obey to count.
Diffstat (limited to 'src/stream.h')
| -rw-r--r-- | src/stream.h | 2 |
1 files changed, 1 insertions, 1 deletions
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 |