MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / streamIteratorStop

Function streamIteratorStop

src/t_stream.cpp:1314–1316  ·  view source on GitHub ↗

Stop the stream iterator. The only cleanup we need is to free the rax * iterator, since the stream iterator itself is supposed to be stack * allocated. */

Source from the content-addressed store, hash-verified

1312 * iterator, since the stream iterator itself is supposed to be stack
1313 * allocated. */
1314void streamIteratorStop(streamIterator *si) {
1315 raxStop(&si->ri);
1316}
1317
1318/* Delete the specified item ID from the stream, returning 1 if the item
1319 * was deleted 0 otherwise (if it does not exist). */

Callers 7

streamDeleteItemFunction · 0.85
streamLastValidIDFunction · 0.85
streamReplyWithRangeFunction · 0.85
xclaimCommandFunction · 0.85
xorObjectDigestFunction · 0.85
rewriteStreamObjectFunction · 0.85

Calls 1

raxStopFunction · 0.85

Tested by

no test coverage detected