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