MCPcopy Create free account
hub / github.com/acl-dev/acl / show_messages

Function show_messages

lib_acl_cpp/samples/redis/redis_stream/redis_stream.cpp:138–151  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

136}
137
138static void show_messages(const acl::redis_stream_messages& messages)
139{
140 size_t i = 0;
141 printf("key=%s\r\n", messages.key.c_str());
142 for (std::vector<acl::redis_stream_message>::const_iterator
143 it = messages.messages.begin(); it != messages.messages.end();
144 ++it) {
145
146 if (++i <= 10) {
147 show_message(*it);
148 }
149 }
150 printf("total messages count=%lu\r\n", (unsigned long) messages.size());
151}
152
153static void xreadgroup(acl::redis_stream& redis, const char* group,
154 const char* consumer)

Callers 4

xreadgroupFunction · 0.85
xreadFunction · 0.85
xrangeFunction · 0.85
xrevrangeFunction · 0.85

Calls 5

show_messageFunction · 0.85
beginMethod · 0.80
c_strMethod · 0.45
endMethod · 0.45
sizeMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…