From e7c579e1fe0fdcdf631e27a5fd17e36f621ddef3 Mon Sep 17 00:00:00 2001 From: antirez Date: Mon, 5 Nov 2018 13:06:01 +0100 Subject: [PATCH] Improve streamReplyWithRange() top comment. --- src/t_stream.c | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/src/t_stream.c b/src/t_stream.c index e37b6582..cb7e2594 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -847,11 +847,15 @@ void streamPropagateGroupID(client *c, robj *key, streamCG *group, robj *groupna decrRefCount(argv[4]); } -/* Send the specified range to the client 'c'. The range the client will - * receive is between start and end inclusive, if 'count' is non zero, no more - * than 'count' elements are sent. The 'end' pointer can be NULL to mean that - * we want all the elements from 'start' till the end of the stream. If 'rev' - * is non zero, elements are produced in reversed order from end to start. +/* Send the stream items in the specified range to the client 'c'. The range + * the client will receive is between start and end inclusive, if 'count' is + * non zero, no more than 'count' elements are sent. + * + * The 'end' pointer can be NULL to mean that we want all the elements from + * 'start' till the end of the stream. If 'rev' is non zero, elements are + * produced in reversed order from end to start. + * + * The function returns the number of entries emitted. * * If group and consumer are not NULL, the function performs additional work: * 1. It updates the last delivered ID in the group in case we are