diff options
author | antirez <antirez@gmail.com> | 2018-01-24 18:51:23 +0100 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
commit | aa808394f64ce735311f63bea1a142d5fab9bc82 (patch) | |
tree | 6c55764fc5543fce465020c3678f75ba7623af1a /src/stream.h | |
parent | bbec4569a57df0ee14e64f64caa6bb0b12c7f9db (diff) | |
download | redis-aa808394f64ce735311f63bea1a142d5fab9bc82.tar.gz |
CG: first draft of streamReplyWithRangeFromConsumerPEL().
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 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); |