From aa808394f64ce735311f63bea1a142d5fab9bc82 Mon Sep 17 00:00:00 2001 From: antirez Date: Wed, 24 Jan 2018 18:51:23 +0100 Subject: CG: first draft of streamReplyWithRangeFromConsumerPEL(). --- 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 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); -- cgit v1.2.1