XACKDEL

// Acknowledge and delete a single entryconst result = await redis.xackdel("mystream", "mygroup", "KEEPREF", "1638360173533-0");console.log(result); // Array of results for each ID

// Acknowledge and delete multiple entriesconst result = await redis.xackdel(  "mystream",  "mygroup",  "KEEPREF",  "1638360173533-0",  "1638360173533-1",  "1638360173533-2");console.log(result); // Array of results for each ID

// Keep consumer group references when deleting entries// Useful when you want to delete entries but maintain group trackingconst result = await redis.xackdel(  "mystream",  "mygroup",  "KEEPREF",  "1638360173533-0",  "1638360173533-1",);console.log(result); // Array of results for each ID

// Delete consumer group references along with entries// Useful for complete cleanup of processed messagesconst result = await redis.xackdel(  "mystream",  "mygroup",  "DELREF",  "1638360173533-0",  "1638360173533-1",);console.log(result); // Array of results for each ID

// Acknowledge for this group, but only delete the entry// once every other consumer group has acknowledged it tooconst result = await redis.xackdel(  "mystream",  "mygroup",  "ACKED",  "1638360173533-0",);console.log(result); // [1] if deleted, [2] if another group still needs it

// Create a consumer groupawait redis.xgroup("orders", {  type: "CREATE",  group: "processors",  id: "0",  options: { MKSTREAM: true },});// Add some orders to the streamawait redis.xadd("orders", "*", { order_id: "123", status: "pending" });await redis.xadd("orders", "*", { order_id: "124", status: "pending" });// Read messages as a consumerconst messages = await redis.xreadgroup("processors", "consumer1", "orders", ">", {  count: 2,}) as [string, [string, unknown[]][]][];// Process messages and acknowledge + delete themfor (const [stream, entries] of messages) {  for (const [id, fields] of entries) {    // Process the order...    console.log(`Processing order ${id}`, fields);        // Acknowledge and delete the entry, keeping references in other groups    await redis.xackdel("orders", "processors", "KEEPREF", id);        // Or use DELREF for complete cleanup    // await redis.xackdel("orders", "processors", "DELREF", id);  }}

// Read pending messagesconst pending = await redis.xreadgroup("tasks", "worker1", "task-queue", ">", {  count: 10,}) as [string, [string, unknown[]][]][];if (pending && pending.length > 0) {  const [stream, entries] = pending[0];  const processedIds: string[] = [];    // Process each task  for (const [id, fields] of entries) {    try {      // Process task...      console.log(`Processing task ${id}`);      processedIds.push(id);    } catch (error) {      console.error(`Failed to process ${id}:`, error);    }  }    // Acknowledge and delete all successfully processed tasks  // Using DELREF to completely remove references  if (processedIds.length > 0) {    const result = await redis.xackdel("task-queue", "tasks", "DELREF", ...processedIds);    console.log(`Results: ${result}`); // Array of results for each ID  }}