From 96fdc7794bbdf86bec13421a18c786fec18b0159 Mon Sep 17 00:00:00 2001
From: Guy Korland <gkorland@gmail.com>
Date: Mon, 12 Nov 2018 17:36:41 +0200
Subject: [PATCH] add a simple streams example

---
 examples/streams.js | 47 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 47 insertions(+)
 create mode 100644 examples/streams.js

diff --git a/examples/streams.js b/examples/streams.js
new file mode 100644
index 0000000000..1aeeca0a08
--- /dev/null
+++ b/examples/streams.js
@@ -0,0 +1,47 @@
+'use strict';
+
+var redis = require('redis');
+var client1 = redis.createClient();
+var client2 = redis.createClient();
+var client3 = redis.createClient();
+
+client1.xadd('mystream', '*', 'field1', 'm1',  function (err) {
+	if(err){
+	    return console.error(err);	
+	}
+	client1.xgroup('CREATE', 'mystream', 'mygroup', '$',  function (err) {
+		if(err){
+		    return console.error(err);	
+		}
+	});
+	
+	client2.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, 
+			'STREAMS', 'mystream', '>',  function (err, stream) {
+		if(err){
+		    return console.error(err);	
+		}
+	    console.log('client2 ' + stream);
+	});
+	
+	client3.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, 
+			'STREAMS', 'mystream', '>',  function (err, stream) {
+		if(err){
+		    return console.error(err);	
+		}
+	    console.log('client3 ' + stream);
+	});
+
+	
+	client1.xadd('mystream', '*', 'field1', 'm2',  function (err) {
+		if(err){
+		    return console.error(err);	
+		}
+	});
+	
+	client1.xadd('mystream', '*', 'field1', 'm3',  function (err) {
+		if(err){
+		    return console.error(err);	
+		}
+	});
+
+});