From e12ff2aa13513c73396511b4baa6c6f4f797a0bc Mon Sep 17 00:00:00 2001
From: David Libeau <contact@davidlibeau.fr>
Date: Sat, 28 Aug 2021 18:16:26 +0200
Subject: [PATCH] Improve stream examples with the `includes` object

---
 README.md                 | 14 +++++++++-----
 examples/stream_tweets.js |  2 +-
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/README.md b/README.md
index 3406132..f85eb69 100644
--- a/README.md
+++ b/README.md
@@ -102,8 +102,9 @@ setTimeout(() => {
   stream.close();
 }, 30000);
 
-for await (const { data } of stream) {
-  console.log(data);
+for await (const { data, includes } of stream) {
+  console.log("data", data);
+  console.log("includes", includes);
 }
 ```
 
@@ -122,8 +123,8 @@ these cases. For example:
 ```js
 async function listenForever(streamFactory, dataConsumer) {
   try {
-    for await (const { data } of streamFactory()) {
-      dataConsumer(data);
+    for await (const { data, includes } of streamFactory()) {
+      dataConsumer(data, includes);
     }
     // The stream has been closed by Twitter. It is usually safe to reconnect.
     console.log('Stream disconnected healthily. Reconnecting.');
@@ -139,7 +140,10 @@ async function listenForever(streamFactory, dataConsumer) {
 
 listenForever(
   () => client.stream('tweets/search/stream'),
-  (data) => console.log(data)
+  (data, includes) => {
+    console.log("data", data);
+    console.log("includes", includes);
+  }
 );
 ```
 
diff --git a/examples/stream_tweets.js b/examples/stream_tweets.js
index 2b5ad69..1606681 100644
--- a/examples/stream_tweets.js
+++ b/examples/stream_tweets.js
@@ -14,7 +14,7 @@ async function main() {
   }, 30 * 1000);
 
   // Read data from the stream
-  for await (const { data } of stream) {
+  for await (const { data, includes } of stream) {
     console.log(`${data.id}: ${data.text.replace(/\s/g, ' ')}`);
   }