server/modules/selva/module/subscriptions.c
static void remove_sub_markers(RedisModuleCtx *ctx, SelvaModify_Hierarchy *hierarchy, struct Selva_Subscription *sub) {
    if (SVector_Size(&sub->markers) > 0) {
        struct Selva_SubscriptionMarker *marker;

        while ((marker = SVector_Shift(&sub->markers))) {
            do_sub_marker_removal(ctx, hierarchy, marker);
        }
        SVector_ShiftReset(&sub->markers);
    }
}
/**
 * Remove and destroy all markers of a subscription.
 */
Remove and destroy all markers of a subscription.
Remove and destroy all markers of a subscription .
static void remove_sub_markers(RedisModuleCtx *ctx, SelvaModify_Hierarchy *hierarchy, struct Selva_Subscription *sub) {
    if (SVector_Size(&sub->markers) > 0) {
        struct Selva_SubscriptionMarker *marker;
        while ((marker = SVector_Shift(&sub->markers))) {
            do_sub_marker_removal(ctx, hierarchy, marker);
        }
        SVector_ShiftReset(&sub->markers);
    }
}
static void remove_sub_markers ( RedisModuleCtx * ctx , SelvaModify_Hierarchy * hierarchy , struct Selva_Subscription * sub ) { if ( SVector_Size ( & sub -> markers ) > 0 ) { struct Selva_SubscriptionMarker * marker ; while ( ( marker = SVector_Shift ( & sub -> markers ) ) ) { do_sub_marker_removal ( ctx , hierarchy , marker ) ; } SVector_ShiftReset ( & sub -> markers ) ; } }
Remove and destroy all markers of a subscription.
Remove and destroy all markers of a subscription .