summaryrefslogtreecommitdiff
path: root/src/stream.h
diff options
context:
space:
mode:
authorantirez <antirez@gmail.com>2018-01-24 18:51:23 +0100
committerantirez <antirez@gmail.com>2018-03-15 12:54:10 +0100
commitaa808394f64ce735311f63bea1a142d5fab9bc82 (patch)
tree6c55764fc5543fce465020c3678f75ba7623af1a /src/stream.h
parentbbec4569a57df0ee14e64f64caa6bb0b12c7f9db (diff)
downloadredis-aa808394f64ce735311f63bea1a142d5fab9bc82.tar.gz
CG: first draft of streamReplyWithRangeFromConsumerPEL().
Diffstat (limited to 'src/stream.h')
-rw-r--r--src/stream.h2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/stream.h b/src/stream.h
index fa6947482..917392076 100644
--- a/src/stream.h
+++ b/src/stream.h
@@ -89,7 +89,7 @@ struct client;
stream *streamNew(void);
void freeStream(stream *s);
-size_t streamReplyWithRange(struct client *c, stream *s, streamID *start, streamID *end, size_t count, int rev, streamCG *group, streamConsumer *consumer, int noack);
+size_t streamReplyWithRange(struct client *c, stream *s, streamID *start, streamID *end, size_t count, int rev, streamCG *group, streamConsumer *consumer, int flags);
void streamIteratorStart(streamIterator *si, stream *s, streamID *start, streamID *end, int rev);
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);