diff --git a/examples/stream-producer.js b/examples/stream-producer.js
index 42c5d14bb2..00d6dab7ae 100644
--- a/examples/stream-producer.js
+++ b/examples/stream-producer.js
@@ -1,25 +1,51 @@
 // A sample stream producer using XADD.
-
 import { createClient } from 'redis';
 
 async function streamProducer() {
   const client = createClient();
 
   await client.connect();
+  
+  for (let i = 0; i < 10000; i++) {
+    await client.xAdd(
+      'mystream',
+      '*', // * = Let Redis generate a timestamp ID for this new entry.
+      // Payload to add to the stream:
+      {
+        i: i.toString()
+        // Other name/value pairs can go here as required...
+      }
+    );
 
-  let num = 0;
+    // Also add to a stream whose length we will cap at approximately
+    // 1000 entries using the MAXLEN trimming strategy:
+    // https://redis.io/commands/xadd/
 
-  while (num < 1000) {
-    // * = Let Redis generate a timestamp ID for this new entry.
-    let id = await client.xAdd('mystream', '*', {
-      num: `${num}`
-      // Other name/value pairs can go here as required...
-    });
-
-    console.log(`Added ${id} to the stream.`);
-    num += 1;
+    await client.xAdd(
+      'mytrimmedstream', 
+      id, // Re-use the ID from the previous stream.
+      // Payload to add to the stream:
+      {
+        i: i.toString()
+        // Other name/value pairs can go here as required...
+      },
+      // Specify a trimming strategy...
+      {
+        TRIM: {
+          strategy: 'MAXLEN', // Trim by length.
+          strategyModifier: '~', // Approximate trimming.
+          threshold: 1000 // Retain around 1000 entries.
+        }
+      }
+    );
   }
 
+  // Take a look at how many entries are in the streams...
+  // Should be 10000:
+  console.log(`Length of mystream: ${await client.xLen('mystream')}.`);
+  // Should be approximately 1000:
+  console.log(`Length of mytrimmedstream: ${await client.xLen('mytrimmedstream')}.`);
+
   await client.quit();
 }