From c3ffd3693688104bac2da8ec04a3ba9ccc190aca Mon Sep 17 00:00:00 2001
From: Jeevananthan-23 <jeeva023@outlook.com>
Date: Mon, 30 Jan 2023 15:20:13 +0530
Subject: [PATCH 1/9] added pipelineexamples and docs

---
 Examples/CombinationModulesPipeline.md        | 46 +++++++++++++
 Examples/PipelineExample.md                   | 42 ++++++++++++
 .../Examples/ExamplesTests.cs                 | 66 +++++++++++++++++++
 3 files changed, 154 insertions(+)
 create mode 100644 Examples/CombinationModulesPipeline.md
 create mode 100644 Examples/PipelineExample.md

diff --git a/Examples/CombinationModulesPipeline.md b/Examples/CombinationModulesPipeline.md
new file mode 100644
index 00000000..4dcdffca
--- /dev/null
+++ b/Examples/CombinationModulesPipeline.md
@@ -0,0 +1,46 @@
+# Combination modules Pipeline 
+## An example of pipelines mixing a pipeline with a combination of module commands with JSON & Search
+
+### Connect to the Redis server:
+```csharp
+var redis = ConnectionMultiplexer.Connect("localhost");
+```
+
+### Setup pipeline connection
+```csharp
+var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+```
+
+### Add JsonSet to pipeline
+```csharp
+pipeline.Json.SetAsync("person:01", "$", new { name = "John", age = 30, city = "New York" });
+pipeline.Json.SetAsync("person:02", "$", new { name = "Joy", age = 25, city = "Los Angeles" });
+pipeline.Json.SetAsync("person:03", "$", new { name = "Mark", age = 21, city = "Chicago" });
+pipeline.Json.SetAsync("person:04", "$", new { name = "Steve", age = 24, city = "Phoenix" });
+pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city = "San Antonio" });
+```
+
+### Create the schema to index first and age as a numeric field
+```csharp
+var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddTagField("city");
+```
+
+### Filter the index to only include Jsons and prefix of person
+```csharp
+var parameters = FTCreateParams.CreateParams().On(Literals.Enums.IndexDataType.JSON).Prefix("person:");
+```
+
+### Create the index via pipeline
+```csharp
+pipeline.Ft.CreateAsync("person-idx", parameters, schema);
+```
+
+### Search for all indexed person records
+```csharp
+var getAllPersons = pipeline.Ft.SearchAsync("person-idx", new Query());
+```
+
+### Execute the pipeline
+```csharp
+pipeline.Execute();
+```
\ No newline at end of file
diff --git a/Examples/PipelineExample.md b/Examples/PipelineExample.md
new file mode 100644
index 00000000..a0c32100
--- /dev/null
+++ b/Examples/PipelineExample.md
@@ -0,0 +1,42 @@
+# Pipeline 
+## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
+
+### Connect to the Redis server:
+```csharp
+var redis = ConnectionMultiplexer.Connect("localhost");
+```
+
+### Setup pipeline connection
+```csharp
+var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+```
+
+### Add JsonSet to pipeline
+```csharp
+pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
+```
+
+### Inc age by 2 
+```csharp
+pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
+```
+
+### Clear the nicknames from the Json
+```csharp
+pipeline.Json.ClearAsync("person", "$.nicknames");
+```
+
+### Del the nicknames
+```csharp
+pipeline.Json.DelAsync("person", "$.nicknames");
+```
+
+### Get the Json response
+```csharp
+var getResponse = pipeline.Json.GetAsync("person");
+```
+
+### Execute the pipeline
+```csharp
+pipeline.Execute();
+```
\ No newline at end of file
diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index 9473dba1..e8752a01 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -73,4 +73,70 @@ public async Task AsyncExample()
         await json.SetAsync("key", "$", new { name = "John", age = 30, city = "New York" });
         var john = await json.GetAsync("key");
     }
+
+    [Fact]
+    public void PipelineExample()
+    {
+        //Setup pipeline connection
+        var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+
+        // Add JsonSet to pipeline
+        pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
+
+        // Inc age by 2 
+        pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
+
+        // Clear the nicknames from the Json
+        pipeline.Json.ClearAsync("person", "$.nicknames");
+
+        // Del the nicknames
+        pipeline.Json.DelAsync("person", "$.nicknames");
+
+        // Get the Json response
+        var getResponse = pipeline.Json.GetAsync("person");
+
+        // Execute the pipeline
+        pipeline.Execute();
+    }
+
+    [Fact]
+    public void JsonWithSearchPipeline()
+    {
+        // Setup pipeline connection
+        var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+
+        // Add JsonSet to pipeline
+        pipeline.Json.SetAsync("person:01", "$", new { name = "John", age = 30, city = "New York" });
+        pipeline.Json.SetAsync("person:02", "$", new { name = "Joy", age = 25, city = "Los Angeles" });
+        pipeline.Json.SetAsync("person:03", "$", new { name = "Mark", age = 21, city = "Chicago" });
+        pipeline.Json.SetAsync("person:04", "$", new { name = "Steve", age = 24, city = "Phoenix" });
+        pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city = "San Antonio" });
+
+        // Create the schema to index first and age as a numeric field
+        var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddTagField("city");
+
+        // Filter the index to only include Jsons and prefix of person
+        var parameters = FTCreateParams.CreateParams().On(Literals.Enums.IndexDataType.JSON).Prefix("person:");
+
+        // Create the index via pipeline
+        pipeline.Ft.CreateAsync("person-idx", parameters, schema);
+
+        // Search for all indexed person records
+        var getAllPersons = pipeline.Ft.SearchAsync("person-idx", new Query());
+
+        // execute the pipeline
+        pipeline.Execute();
+    }
+
+    [Fact]
+    public async Task PipelineWithAsync()
+    {
+
+    }
+
+    [Fact]
+    public void TransactionExample()
+    {
+        // implementation for transaction
+    }
 }
\ No newline at end of file

From e8fa4f0c491dbd48e0082b06444f109c821ecfa3 Mon Sep 17 00:00:00 2001
From: Jeevananthan-23 <jeeva023@outlook.com>
Date: Mon, 30 Jan 2023 19:13:37 +0530
Subject: [PATCH 2/9] adding pipelinewithAsync example

---
 .../Examples/ExamplesTests.cs                 | 44 +++++++++++++++++++
 1 file changed, 44 insertions(+)

diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index ccbf7f18..c3d86b56 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -4,6 +4,7 @@
 using Moq;
 using NRedisStack.Search.FT.CREATE;
 using NRedisStack.Search;
+using NRedisStack.DataTypes;
 
 namespace NRedisStack.Tests.Bloom;
 
@@ -131,7 +132,50 @@ public void JsonWithSearchPipeline()
     [Fact]
     public async Task PipelineWithAsync()
     {
+        // Connect to the Redis server
+        var redis = ConnectionMultiplexer.Connect("localhost");
+
+        // Get a reference to the database
+        var db = redis.GetDatabase();
+        var ts = db.TS();
+
+        // Setup pipeline connection
+        var pipeline = new Pipeline(redis);
+
+        // create metedata lables for time-series.
+        TimeSeriesLabel label1 = new TimeSeriesLabel("temp", "TLV");
+        TimeSeriesLabel label2 = new TimeSeriesLabel("temp", "JLM");
+        var labels1 = new List<TimeSeriesLabel> { label1 };
+        var labels2 = new List<TimeSeriesLabel> { label2 };
+
+        //create a new time-series.
+        pipeline.Ts.CreateAsync("temp:TLV", labels: labels1);
+        pipeline.Ts.CreateAsync("temp:JLM", labels: labels2);
+
+        //adding multiple sequenece of time-series data.
+        List<(string, TimeStamp, double)> sequence1 = new List<(string, TimeStamp, double)>()
+        {
+            ("temp:TLV",1000,30),
+            ("temp:TLV", 1010 ,35),
+            ("temp:TLV", 1020, 9999),
+            ("temp:TLV", 1030, 40)
+        };
+        List<(string, TimeStamp, double)> sequence2 = new List<(string, TimeStamp, double)>()
+        {
+            ("temp:JLM",1005,30),
+            ("temp:JLM", 1015 ,35),
+            ("temp:JLM", 1025, 9999),
+            ("temp:JLM", 1035, 40)
+        };
+
+        // Adding mutiple samples to mutiple series.
+        pipeline.Ts.MAddAsync(sequence1);
+        pipeline.Ts.MAddAsync(sequence2);
+
+        pipeline.Execute();
 
+        // get only the location label for each last sample, use SELECTED_LABELS.
+        var respons = await ts.MGetAsync(new List<string> { "temp=JLM" }, selectedLabels: new List<string> { "location" });
     }
 
     [Fact]

From 1c26a8cae01044e05f91ac685986ba015d3af6a0 Mon Sep 17 00:00:00 2001
From: Chayim <chayim@users.noreply.github.com>
Date: Mon, 30 Jan 2023 17:09:28 +0200
Subject: [PATCH 3/9] Adding a README to the nuget package (#76)

* Adding a README to the nuget package

* readme path

* fixing readme path
---
 .github/workflows/integration.yml  | 2 ++
 src/NRedisStack/NRedisStack.csproj | 4 +++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/.github/workflows/integration.yml b/.github/workflows/integration.yml
index edbac4fc..d4029f67 100644
--- a/.github/workflows/integration.yml
+++ b/.github/workflows/integration.yml
@@ -43,3 +43,5 @@ jobs:
           token: ${{secrets.CODECOV_TOKEN}}
           verbose: true
 
+      - name: Build
+        run: dotnet pack -c Release --output .
diff --git a/src/NRedisStack/NRedisStack.csproj b/src/NRedisStack/NRedisStack.csproj
index 93f75b2a..33986676 100644
--- a/src/NRedisStack/NRedisStack.csproj
+++ b/src/NRedisStack/NRedisStack.csproj
@@ -7,13 +7,15 @@
 	<Authors>Redis Open Source</Authors>
 	<Owners>Redis OSS</Owners>
 	<Description>.Net Client for Redis Stack</Description>
+	<PackageReadmeFile>README.md</PackageReadmeFile>
 	<Version>0.5.0</Version>
 	<ReleaseVersion>0.5.0</ReleaseVersion>
 	<PackageVersion>0.5.0</PackageVersion>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="StackExchange.Redis" Version="2.6.45" />
+	<PackageReference Include="StackExchange.Redis" Version="2.6.45" />
+	<None Include="..\..\README.md" Pack="true" PackagePath="\" />
   </ItemGroup>
 
 </Project>

From 7ee38b6f37d70d148fe09d71867a86f3a5f796cb Mon Sep 17 00:00:00 2001
From: Jeevananthan-23 <jeeva023@outlook.com>
Date: Tue, 31 Jan 2023 19:25:54 +0530
Subject: [PATCH 4/9] adding pipelinewithasync doc feedback changes

---
 Examples/AsyncExample.md                      | 14 ++--
 Examples/CombinationModulesPipeline.md        | 18 ++---
 Examples/HsetAndSearch.md                     | 29 ++++----
 Examples/PipelineExample.md                   | 20 +++---
 Examples/PipelineWithAsync.md                 | 70 +++++++++++++++++++
 .../Examples/ExamplesTests.cs                 | 17 ++++-
 6 files changed, 128 insertions(+), 40 deletions(-)
 create mode 100644 Examples/PipelineWithAsync.md

diff --git a/Examples/AsyncExample.md b/Examples/AsyncExample.md
index 40ec4673..a5fff4b6 100644
--- a/Examples/AsyncExample.md
+++ b/Examples/AsyncExample.md
@@ -3,17 +3,17 @@
 
 ## All methods have synchronous & asynchronous implementation. the asynchronous methods all end ...Async(...), and are fully await-able. here is an example of using the async methods:
 
-### Connect to the Redis server and get a reference to the database and for JSON commands:
+Connect to the Redis server and get a reference to the database and for JSON commands:
 
 ```csharp
-        var redis = await ConnectionMultiplexer.ConnectAsync("localhost");
-        var db = redis.GetDatabase();
-        var json = db.JSON();
+var redis = await ConnectionMultiplexer.ConnectAsync("localhost");
+var db = redis.GetDatabase();
+var json = db.JSON();
 ```
 
-### call async version of JSON.SET/GET
+call async version of JSON.SET/GET
 
 ```csharp
-        await json.SetAsync("key", "$", new { name = "John", age = 30, city = "New York" });
-        var john = await json.GetAsync("key");
+await json.SetAsync("key", "$", new { name = "John", age = 30, city = "New York" });
+var john = await json.GetAsync("key");
 ```
diff --git a/Examples/CombinationModulesPipeline.md b/Examples/CombinationModulesPipeline.md
index 4dcdffca..b36b9e0d 100644
--- a/Examples/CombinationModulesPipeline.md
+++ b/Examples/CombinationModulesPipeline.md
@@ -1,17 +1,18 @@
 # Combination modules Pipeline 
 ## An example of pipelines mixing a pipeline with a combination of module commands with JSON & Search
 
-### Connect to the Redis server:
+Connect to the Redis server:
 ```csharp
 var redis = ConnectionMultiplexer.Connect("localhost");
 ```
 
-### Setup pipeline connection
+Setup pipeline connection
 ```csharp
 var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
 ```
 
-### Add JsonSet to pipeline
+## JSON
+Add JsonSet to pipeline
 ```csharp
 pipeline.Json.SetAsync("person:01", "$", new { name = "John", age = 30, city = "New York" });
 pipeline.Json.SetAsync("person:02", "$", new { name = "Joy", age = 25, city = "Los Angeles" });
@@ -20,27 +21,28 @@ pipeline.Json.SetAsync("person:04", "$", new { name = "Steve", age = 24, city =
 pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city = "San Antonio" });
 ```
 
-### Create the schema to index first and age as a numeric field
+## Search
+Create the schema to index first and age as a numeric field
 ```csharp
 var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddTagField("city");
 ```
 
-### Filter the index to only include Jsons and prefix of person
+Filter the index to only include Jsons and prefix of person
 ```csharp
 var parameters = FTCreateParams.CreateParams().On(Literals.Enums.IndexDataType.JSON).Prefix("person:");
 ```
 
-### Create the index via pipeline
+Create the index via pipeline
 ```csharp
 pipeline.Ft.CreateAsync("person-idx", parameters, schema);
 ```
 
-### Search for all indexed person records
+Search for all indexed person records
 ```csharp
 var getAllPersons = pipeline.Ft.SearchAsync("person-idx", new Query());
 ```
 
-### Execute the pipeline
+Execute the pipeline
 ```csharp
 pipeline.Execute();
 ```
\ No newline at end of file
diff --git a/Examples/HsetAndSearch.md b/Examples/HsetAndSearch.md
index aec51415..0b63d167 100644
--- a/Examples/HsetAndSearch.md
+++ b/Examples/HsetAndSearch.md
@@ -1,17 +1,16 @@
-
 # HSET and Search
 ## An example of mixing Redis open source command (HSET) with Redis Stack Redis commands (FT.CREATE & FT.SEARCH)
 
-### Connect to the Redis server:
+Connect to the Redis server:
 ```csharp
 var redis = ConnectionMultiplexer.Connect("localhost");
 ```
-### Get a reference to the database and for search commands:
+Get a reference to the database and for search commands:
 ```csharp
 var db = redis.GetDatabase();
 var ft = db.FT();
 ```
-### Use HSET to add a field-value pair to a hash:
+Use HSET to add a field-value pair to a hash:
 ```csharp
 db.HashSet("profesor:5555", new HashEntry[] { new("first", "Albert"), new("last", "Blue"), new("age", "55") });
 db.HashSet("student:1111", new HashEntry[] { new("first", "Joe"), new("last", "Dod"), new("age", "18") });
@@ -22,40 +21,40 @@ db.HashSet("student:5555", new HashEntry[] { new("first", "Joen"), new("last", "
 db.HashSet("teacher:6666", new HashEntry[] { new("first", "Pat"), new("last", "Rod"), new("age", "20") });
 ```
 
-### Create the schema to index first and last as text fields, and age as a numeric field:
+Create the schema to index first and last as text fields, and age as a numeric field:
 ```csharp
 var schema = new Schema().AddTextField("first").AddTextField("last").AddNumericField("age");
 ```
-### Filter the index to only include hashes with an age greater than 16, and prefix of 'student:' or 'pupil:'
+Filter the index to only include hashes with an age greater than 16, and prefix of 'student:' or 'pupil:'
 ```csharp
 var parameters = FTCreateParams.CreateParams().Filter("@age>16").Prefix("student:", "pupil:");
 ```
-### Create the index:
+Create the index:
 ```csharp
 ft.Create("example_index", parameters, schema);
 ```
 ## Search Examples:
 
-### Search all hashes in the index:
+Search all hashes in the index:
 ```csharp
 var noFilters = ft.Search("example_index", new Query());
 ```
-### _noFilters_ now contains: _student:1111_, _student:5555_, _pupil:4444_, _student:3333_.<br /><br />
+_noFilters_ now contains: _student:1111_, _student:5555_, _pupil:4444_, _student:3333_.<br /><br />
 
-### Search for hashes with a first name starting with Jo
+Search for hashes with a first name starting with Jo
 ```csharp
 var startWithJo = ft.Search("example_index", new Query("@first:Jo*"));
 ```
-### _startWithJo_ now contains: _student:1111_ (Joe), _student:5555_ (Joen).<br /><br />
+_startWithJo_ now contains: _student:1111_ (Joe), _student:5555_ (Joen).<br /><br />
 
-### Search for hashes with first name of Pat
+Search for hashes with first name of Pat
 ```csharp
 var namedPat = ft.Search("example_index", new Query("@first:Pat"));
 ```
-### _namedPat_ now contains _pupil:4444_ (Pat). _teacher:6666_ (Pat) is not included because it does not have a prefix of 'student:' or 'pupil:'<br /><br />
+_namedPat_ now contains _pupil:4444_ (Pat). _teacher:6666_ (Pat) is not included because it does not have a prefix of 'student:' or 'pupil:'<br /><br />
 
-### Search for hashes with last name of Rod
+Search for hashes with last name of Rod
 ```csharp
 var lastNameRod = ft.Search("example_index", new Query("@last:Rod"));
 ```
-### _lastNameRod_ is empty because there are no hashes with a last name of Rod that match the index definition.
\ No newline at end of file
+_lastNameRod_ is empty because there are no hashes with a last name of Rod that match the index definition.
\ No newline at end of file
diff --git a/Examples/PipelineExample.md b/Examples/PipelineExample.md
index a0c32100..a4ae48d2 100644
--- a/Examples/PipelineExample.md
+++ b/Examples/PipelineExample.md
@@ -1,42 +1,46 @@
 # Pipeline 
 ## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
 
-### Connect to the Redis server:
+Connect to the Redis server:
 ```csharp
 var redis = ConnectionMultiplexer.Connect("localhost");
 ```
 
-### Setup pipeline connection
+Setup pipeline connection
 ```csharp
 var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
 ```
 
-### Add JsonSet to pipeline
+Add JsonSet to pipeline
 ```csharp
 pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 ```
 
-### Inc age by 2 
+Inc `age` by 2 
 ```csharp
 pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
 ```
 
-### Clear the nicknames from the Json
+Clear the `nicknames` from the Json
 ```csharp
 pipeline.Json.ClearAsync("person", "$.nicknames");
 ```
 
-### Del the nicknames
+Del the `nicknames`
 ```csharp
 pipeline.Json.DelAsync("person", "$.nicknames");
 ```
 
-### Get the Json response
+Get the Json response
 ```csharp
 var getResponse = pipeline.Json.GetAsync("person");
 ```
 
-### Execute the pipeline
+Execute the pipeline
 ```csharp
 pipeline.Execute();
+```
+Get the result JSON 
+```csharp
+var result = getResponse.Result;
 ```
\ No newline at end of file
diff --git a/Examples/PipelineWithAsync.md b/Examples/PipelineWithAsync.md
new file mode 100644
index 00000000..7463094c
--- /dev/null
+++ b/Examples/PipelineWithAsync.md
@@ -0,0 +1,70 @@
+# Pipeline With Async
+## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
+
+
+Connect to the Redis server
+```csharp
+var redis = ConnectionMultiplexer.Connect("localhost");
+```
+
+Get a reference to the database
+```csharp
+var db = redis.GetDatabase();
+```
+
+Setup pipeline connection
+```csharp
+var pipeline = new Pipeline(redis);
+```
+
+create metedata lables for time-series.
+```csharp
+TimeSeriesLabel label1 = new TimeSeriesLabel("temp", "TLV");
+TimeSeriesLabel label2 = new TimeSeriesLabel("temp", "JLM");
+var labels1 = new List<TimeSeriesLabel> { label1 };
+var labels2 = new List<TimeSeriesLabel> { label2 };
+```
+
+create a new time-series.
+```csharp
+pipeline.Ts.CreateAsync("temp:TLV", labels: labels1);
+pipeline.Ts.CreateAsync("temp:JLM", labels: labels2);
+```
+
+adding multiple sequenece of time-series data.
+```csharp
+List<(string, TimeStamp, double)> sequence1 = new List<(string, TimeStamp, double)>()
+{
+   ("temp:TLV",1000,30),
+   ("temp:TLV", 1010 ,35),
+   ("temp:TLV", 1020, 9999),
+   ("temp:TLV", 1030, 40)
+};
+List<(string, TimeStamp, double)> sequence2 = new List<(string, TimeStamp, double)>()
+{
+   ("temp:JLM",1005,30),
+   ("temp:JLM", 1015 ,35),
+   ("temp:JLM", 1025, 9999),
+   ("temp:JLM", 1035, 40)
+};
+```
+Adding mutiple samples to mutiple series.
+```csharp
+pipeline.Ts.MAddAsync(sequence1);
+pipeline.Ts.MAddAsync(sequence2);
+```
+
+Execute the pipeline
+```csharp
+pipeline.Execute();
+```
+
+Get a reference to the database and for time-series commands
+```csharp
+var ts = db.TS();
+```
+
+get only the location label for each last sample, use SELECTED_LABELS.
+```csharp
+var respons = await ts.MGetAsync(new List<string> { "temp=JLM" }, selectedLabels: new List<string> { "location" });
+```
\ No newline at end of file
diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index c3d86b56..07998139 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -98,12 +98,15 @@ public void PipelineExample()
 
         // Execute the pipeline
         pipeline.Execute();
+        
+        // get the result back JSON
+        var result = getResponse.Result;
     }
 
     [Fact]
     public void JsonWithSearchPipeline()
     {
-        // Setup pipeline connection
+        //Setup pipeline connection
         var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
 
         // Add JsonSet to pipeline
@@ -127,6 +130,13 @@ public void JsonWithSearchPipeline()
 
         // execute the pipeline
         pipeline.Execute();
+
+        // get the total count of people records that indexed.
+        var count =  getAllPersons.Result.TotalResults;
+
+        // Gets the first person form the result.
+        var firstPerson = getAllPersons.Result.Documents.FirstOrDefault();
+        // first person is John here.
     }
 
     [Fact]
@@ -137,7 +147,6 @@ public async Task PipelineWithAsync()
 
         // Get a reference to the database
         var db = redis.GetDatabase();
-        var ts = db.TS();
 
         // Setup pipeline connection
         var pipeline = new Pipeline(redis);
@@ -172,8 +181,12 @@ public async Task PipelineWithAsync()
         pipeline.Ts.MAddAsync(sequence1);
         pipeline.Ts.MAddAsync(sequence2);
 
+        // execute the pipeline
         pipeline.Execute();
 
+        // Get a reference to the database and for time-series commands
+        var ts = db.TS();
+
         // get only the location label for each last sample, use SELECTED_LABELS.
         var respons = await ts.MGetAsync(new List<string> { "temp=JLM" }, selectedLabels: new List<string> { "location" });
     }

From 3ecd26c8500f1bbf8c618376e5b3ac3745a10be3 Mon Sep 17 00:00:00 2001
From: Jeevananthan-23 <jeeva023@outlook.com>
Date: Wed, 1 Feb 2023 21:10:15 +0530
Subject: [PATCH 5/9] feedback changes

---
 Examples/CombinationModulesPipeline.md        |  4 +-
 Examples/PipelineExample.md                   | 40 +++++++----
 Examples/PipelineWithAsync.md                 |  9 ++-
 .../Examples/ExamplesTests.cs                 | 71 +++++++++++++------
 4 files changed, 79 insertions(+), 45 deletions(-)

diff --git a/Examples/CombinationModulesPipeline.md b/Examples/CombinationModulesPipeline.md
index b36b9e0d..9b3d33dd 100644
--- a/Examples/CombinationModulesPipeline.md
+++ b/Examples/CombinationModulesPipeline.md
@@ -22,12 +22,12 @@ pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city
 ```
 
 ## Search
-Create the schema to index first and age as a numeric field
+Create the schema to index name as text field, age as a numeric field and city as tag field.
 ```csharp
 var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddTagField("city");
 ```
 
-Filter the index to only include Jsons and prefix of person
+Filter the index to only include Jsons with prefix of person:
 ```csharp
 var parameters = FTCreateParams.CreateParams().On(Literals.Enums.IndexDataType.JSON).Prefix("person:");
 ```
diff --git a/Examples/PipelineExample.md b/Examples/PipelineExample.md
index a4ae48d2..cd61e3ca 100644
--- a/Examples/PipelineExample.md
+++ b/Examples/PipelineExample.md
@@ -1,46 +1,56 @@
 # Pipeline 
 ## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
 
-Connect to the Redis server:
+Connect to the Redis server and Setup 2 Pipelines
+
+Pipeline can get IDatabase for pipeline1
 ```csharp
-var redis = ConnectionMultiplexer.Connect("localhost");
+IDatabase db = redisFixture.Redis.GetDatabase();
+var pipeline1 = new Pipeline(db);
 ```
 
-Setup pipeline connection
+Pipeline can get IConnectionMultiplexer for pipeline2
 ```csharp
-var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+var redis = ConnectionMultiplexer.Connect("localhost");
+var pipeline2 = new Pipeline(redis);
 ```
 
 Add JsonSet to pipeline
 ```csharp
-pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
+pipeline1.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 ```
 
-Inc `age` by 2 
+Inc age by 2 
 ```csharp
-pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
+pipeline1.Json.NumIncrbyAsync("person", "$.age", 2);
 ```
 
-Clear the `nicknames` from the Json
+Execute the pipeline1
 ```csharp
-pipeline.Json.ClearAsync("person", "$.nicknames");
+pipeline1.Execute();
 ```
 
-Del the `nicknames`
+Clear the nicknames from the Json
 ```csharp
-pipeline.Json.DelAsync("person", "$.nicknames");
+pipeline2.Json.ClearAsync("person", "$.nicknames");
+```
+
+Del the nicknames
+```csharp
+pipeline2.Json.DelAsync("person", "$.nicknames");
 ```
 
 Get the Json response
 ```csharp
-var getResponse = pipeline.Json.GetAsync("person");
+var getResponse = pipeline2.Json.GetAsync("person");
 ```
 
-Execute the pipeline
+Execute the pipeline2
 ```csharp
-pipeline.Execute();
+pipeline2.Execute();
 ```
-Get the result JSON 
+
+Get the result back JSON
 ```csharp
 var result = getResponse.Result;
 ```
\ No newline at end of file
diff --git a/Examples/PipelineWithAsync.md b/Examples/PipelineWithAsync.md
index 7463094c..1385517f 100644
--- a/Examples/PipelineWithAsync.md
+++ b/Examples/PipelineWithAsync.md
@@ -1,7 +1,6 @@
 # Pipeline With Async
 ## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
 
-
 Connect to the Redis server
 ```csharp
 var redis = ConnectionMultiplexer.Connect("localhost");
@@ -17,7 +16,7 @@ Setup pipeline connection
 var pipeline = new Pipeline(redis);
 ```
 
-create metedata lables for time-series.
+Create metedata lables for time-series.
 ```csharp
 TimeSeriesLabel label1 = new TimeSeriesLabel("temp", "TLV");
 TimeSeriesLabel label2 = new TimeSeriesLabel("temp", "JLM");
@@ -25,13 +24,13 @@ var labels1 = new List<TimeSeriesLabel> { label1 };
 var labels2 = new List<TimeSeriesLabel> { label2 };
 ```
 
-create a new time-series.
+Create a new time-series.
 ```csharp
 pipeline.Ts.CreateAsync("temp:TLV", labels: labels1);
 pipeline.Ts.CreateAsync("temp:JLM", labels: labels2);
 ```
 
-adding multiple sequenece of time-series data.
+Adding multiple sequenece of time-series data.
 ```csharp
 List<(string, TimeStamp, double)> sequence1 = new List<(string, TimeStamp, double)>()
 {
@@ -64,7 +63,7 @@ Get a reference to the database and for time-series commands
 var ts = db.TS();
 ```
 
-get only the location label for each last sample, use SELECTED_LABELS.
+Get only the location label for each last sample, use SELECTED_LABELS.
 ```csharp
 var respons = await ts.MGetAsync(new List<string> { "temp=JLM" }, selectedLabels: new List<string> { "location" });
 ```
\ No newline at end of file
diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index 07998139..c45518e7 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -5,8 +5,9 @@
 using NRedisStack.Search.FT.CREATE;
 using NRedisStack.Search;
 using NRedisStack.DataTypes;
+using NRedisStack.Literals.Enums;
 
-namespace NRedisStack.Tests.Bloom;
+namespace NRedisStack.Tests;
 
 public class ExaplesTests : AbstractNRedisStackTest, IDisposable
 {
@@ -74,33 +75,46 @@ public async Task AsyncExample()
         await json.SetAsync("key", "$", new { name = "John", age = 30, city = "New York" });
         var john = await json.GetAsync("key");
     }
-    
+
     [Fact]
     public void PipelineExample()
     {
-        //Setup pipeline connection
-        var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+        // Connect to the Redis server and Setup 2 Pipelines
+
+        // Pipeline can get IDatabase for pipeline1
+        IDatabase db = redisFixture.Redis.GetDatabase();
+        var pipeline1 = new Pipeline(db);
+
+        // Pipeline can get IConnectionMultiplexer for pipeline2
+        var redis = ConnectionMultiplexer.Connect("localhost");
+        var pipeline2 = new Pipeline(redis);
 
         // Add JsonSet to pipeline
-        pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
+        pipeline1.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 
         // Inc age by 2 
-        pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
+        pipeline1.Json.NumIncrbyAsync("person", "$.age", 2);
+
+        // Execute the pipeline1
+        pipeline1.Execute();
 
         // Clear the nicknames from the Json
-        pipeline.Json.ClearAsync("person", "$.nicknames");
+        pipeline2.Json.ClearAsync("person", "$.nicknames");
 
         // Del the nicknames
-        pipeline.Json.DelAsync("person", "$.nicknames");
+        pipeline2.Json.DelAsync("person", "$.nicknames");
 
         // Get the Json response
-        var getResponse = pipeline.Json.GetAsync("person");
+        var getResponse = pipeline2.Json.GetAsync("person");
 
-        // Execute the pipeline
-        pipeline.Execute();
-        
-        // get the result back JSON
+        // Execute the pipeline2
+        pipeline2.Execute();
+
+        // Get the result back JSON
         var result = getResponse.Result;
+
+        // Assert the result
+        Assert.NotNull(result);
     }
 
     [Fact]
@@ -116,11 +130,11 @@ public void JsonWithSearchPipeline()
         pipeline.Json.SetAsync("person:04", "$", new { name = "Steve", age = 24, city = "Phoenix" });
         pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city = "San Antonio" });
 
-        // Create the schema to index first and age as a numeric field
+        // Create the schema to index name as text field, age as a numeric field and city as tag field.
         var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddTagField("city");
 
-        // Filter the index to only include Jsons and prefix of person
-        var parameters = FTCreateParams.CreateParams().On(Literals.Enums.IndexDataType.JSON).Prefix("person:");
+        // Filter the index to only include Jsons with prefix of person:
+        var parameters = FTCreateParams.CreateParams().On(IndexDataType.JSON).Prefix("person:");
 
         // Create the index via pipeline
         pipeline.Ft.CreateAsync("person-idx", parameters, schema);
@@ -131,12 +145,18 @@ public void JsonWithSearchPipeline()
         // execute the pipeline
         pipeline.Execute();
 
-        // get the total count of people records that indexed.
-        var count =  getAllPersons.Result.TotalResults;
+        // Get the total count of people records that indexed.
+        var count = getAllPersons.Result.TotalResults;
 
         // Gets the first person form the result.
         var firstPerson = getAllPersons.Result.Documents.FirstOrDefault();
         // first person is John here.
+
+        // Assert
+
+        Assert.Equal(5, count);
+
+        Assert.Equal("person:01", firstPerson?.Id);
     }
 
     [Fact]
@@ -151,17 +171,18 @@ public async Task PipelineWithAsync()
         // Setup pipeline connection
         var pipeline = new Pipeline(redis);
 
-        // create metedata lables for time-series.
+
+        // Create metedata lables for time-series.
         TimeSeriesLabel label1 = new TimeSeriesLabel("temp", "TLV");
         TimeSeriesLabel label2 = new TimeSeriesLabel("temp", "JLM");
         var labels1 = new List<TimeSeriesLabel> { label1 };
         var labels2 = new List<TimeSeriesLabel> { label2 };
 
-        //create a new time-series.
+        // Create a new time-series.
         pipeline.Ts.CreateAsync("temp:TLV", labels: labels1);
         pipeline.Ts.CreateAsync("temp:JLM", labels: labels2);
 
-        //adding multiple sequenece of time-series data.
+        // Adding multiple sequenece of time-series data.
         List<(string, TimeStamp, double)> sequence1 = new List<(string, TimeStamp, double)>()
         {
             ("temp:TLV",1000,30),
@@ -181,14 +202,18 @@ public async Task PipelineWithAsync()
         pipeline.Ts.MAddAsync(sequence1);
         pipeline.Ts.MAddAsync(sequence2);
 
-        // execute the pipeline
+        // Execute the pipeline
         pipeline.Execute();
 
         // Get a reference to the database and for time-series commands
         var ts = db.TS();
 
-        // get only the location label for each last sample, use SELECTED_LABELS.
+        // Get only the location label for each last sample, use SELECTED_LABELS.
         var respons = await ts.MGetAsync(new List<string> { "temp=JLM" }, selectedLabels: new List<string> { "location" });
+
+        // Assert the respons
+        Assert.Equal(1, respons.Count);
+        Assert.Equal("temp:JLM", respons[0].key);
     }
 
     [Fact]

From 895762ff0aaf70c5fa2242ca4c40b75fd458d404 Mon Sep 17 00:00:00 2001
From: shacharPash <shachar.pashchur@redis.com>
Date: Thu, 2 Feb 2023 17:04:53 +0200
Subject: [PATCH 6/9] fix examples

---
 Examples/CombinationModulesPipeline.md        |  4 ++--
 Examples/PipelineExample.md                   | 12 ++++++------
 .../Examples/ExamplesTests.cs                 | 19 +++++++++++--------
 3 files changed, 19 insertions(+), 16 deletions(-)

diff --git a/Examples/CombinationModulesPipeline.md b/Examples/CombinationModulesPipeline.md
index 9b3d33dd..7224677d 100644
--- a/Examples/CombinationModulesPipeline.md
+++ b/Examples/CombinationModulesPipeline.md
@@ -1,4 +1,4 @@
-# Combination modules Pipeline 
+# Combination modules Pipeline
 ## An example of pipelines mixing a pipeline with a combination of module commands with JSON & Search
 
 Connect to the Redis server:
@@ -29,7 +29,7 @@ var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddT
 
 Filter the index to only include Jsons with prefix of person:
 ```csharp
-var parameters = FTCreateParams.CreateParams().On(Literals.Enums.IndexDataType.JSON).Prefix("person:");
+var parameters = FTCreateParams.CreateParams().On(IndexDataType.JSON).Prefix("person:");
 ```
 
 Create the index via pipeline
diff --git a/Examples/PipelineExample.md b/Examples/PipelineExample.md
index cd61e3ca..12e2fe9a 100644
--- a/Examples/PipelineExample.md
+++ b/Examples/PipelineExample.md
@@ -1,4 +1,4 @@
-# Pipeline 
+# Pipeline
 ## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
 
 Connect to the Redis server and Setup 2 Pipelines
@@ -20,12 +20,12 @@ Add JsonSet to pipeline
 pipeline1.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 ```
 
-Inc age by 2 
+Increase age by 2
 ```csharp
 pipeline1.Json.NumIncrbyAsync("person", "$.age", 2);
 ```
 
-Execute the pipeline1
+Execute pipeline1
 ```csharp
 pipeline1.Execute();
 ```
@@ -35,7 +35,7 @@ Clear the nicknames from the Json
 pipeline2.Json.ClearAsync("person", "$.nicknames");
 ```
 
-Del the nicknames
+Delete the nicknames
 ```csharp
 pipeline2.Json.DelAsync("person", "$.nicknames");
 ```
@@ -45,12 +45,12 @@ Get the Json response
 var getResponse = pipeline2.Json.GetAsync("person");
 ```
 
-Execute the pipeline2
+Execute pipeline2
 ```csharp
 pipeline2.Execute();
 ```
 
-Get the result back JSON
+Get the result of getResponse
 ```csharp
 var result = getResponse.Result;
 ```
\ No newline at end of file
diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index c45518e7..acac6e4f 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -28,6 +28,7 @@ public void HSETandSearch()
 
         // Get a reference to the database and for search commands:
         var db = redis.GetDatabase();
+        db.Execute("FLUSHALL");
         var ft = db.FT();
 
         // Use HSET to add a field-value pair to a hash
@@ -69,6 +70,7 @@ public async Task AsyncExample()
         // Connect to the Redis server
         var redis = await ConnectionMultiplexer.ConnectAsync("localhost");
         var db = redis.GetDatabase();
+        db.Execute("FLUSHALL");
         var json = db.JSON();
 
         // call async version of JSON.SET/GET
@@ -83,6 +85,7 @@ public void PipelineExample()
 
         // Pipeline can get IDatabase for pipeline1
         IDatabase db = redisFixture.Redis.GetDatabase();
+        db.Execute("FLUSHALL");
         var pipeline1 = new Pipeline(db);
 
         // Pipeline can get IConnectionMultiplexer for pipeline2
@@ -92,7 +95,7 @@ public void PipelineExample()
         // Add JsonSet to pipeline
         pipeline1.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 
-        // Inc age by 2 
+        // Increase age by 2
         pipeline1.Json.NumIncrbyAsync("person", "$.age", 2);
 
         // Execute the pipeline1
@@ -114,7 +117,8 @@ public void PipelineExample()
         var result = getResponse.Result;
 
         // Assert the result
-        Assert.NotNull(result);
+        var expected = "{\"name\":\"John\",\"age\":32,\"city\":\"New York\"}";
+        Assert.Equal(expected, result.ToString());
     }
 
     [Fact]
@@ -122,6 +126,7 @@ public void JsonWithSearchPipeline()
     {
         //Setup pipeline connection
         var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+        pipeline.Db.ExecuteAsync("FLUSHALL");
 
         // Add JsonSet to pipeline
         pipeline.Json.SetAsync("person:01", "$", new { name = "John", age = 30, city = "New York" });
@@ -146,16 +151,14 @@ public void JsonWithSearchPipeline()
         pipeline.Execute();
 
         // Get the total count of people records that indexed.
-        var count = getAllPersons.Result.TotalResults;
+        var getAllPersonsResult = getAllPersons.Result;
+        var count = getAllPersonsResult.TotalResults;
 
         // Gets the first person form the result.
-        var firstPerson = getAllPersons.Result.Documents.FirstOrDefault();
+        var firstPerson = getAllPersonsResult.Documents.FirstOrDefault();
         // first person is John here.
 
-        // Assert
-
         Assert.Equal(5, count);
-
         Assert.Equal("person:01", firstPerson?.Id);
     }
 
@@ -167,7 +170,7 @@ public async Task PipelineWithAsync()
 
         // Get a reference to the database
         var db = redis.GetDatabase();
-
+        db.Execute("FLUSHALL");
         // Setup pipeline connection
         var pipeline = new Pipeline(redis);
 

From ae7dccf3e38c8889bad6f8c7a15078881cb52104 Mon Sep 17 00:00:00 2001
From: shacharPash <shachar.pashchur@redis.com>
Date: Sun, 5 Feb 2023 15:59:54 +0200
Subject: [PATCH 7/9] fix JsonWithSearchPipeline test

---
 .../Examples/ExamplesTests.cs                 | 35 ++++++++++---------
 1 file changed, 19 insertions(+), 16 deletions(-)

diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index acac6e4f..a680392c 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -122,18 +122,19 @@ public void PipelineExample()
     }
 
     [Fact]
-    public void JsonWithSearchPipeline()
+    public async Task JsonWithSearchPipeline()
     {
+        IDatabase db = redisFixture.Redis.GetDatabase();
+        db.Execute("FLUSHALL");
         //Setup pipeline connection
-        var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
-        pipeline.Db.ExecuteAsync("FLUSHALL");
+        var pipeline = new Pipeline(db);
 
         // Add JsonSet to pipeline
-        pipeline.Json.SetAsync("person:01", "$", new { name = "John", age = 30, city = "New York" });
-        pipeline.Json.SetAsync("person:02", "$", new { name = "Joy", age = 25, city = "Los Angeles" });
-        pipeline.Json.SetAsync("person:03", "$", new { name = "Mark", age = 21, city = "Chicago" });
-        pipeline.Json.SetAsync("person:04", "$", new { name = "Steve", age = 24, city = "Phoenix" });
-        pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city = "San Antonio" });
+        _ = pipeline.Json.SetAsync("person:01", "$", new { name = "John", age = 30, city = "New York" });
+        _ = pipeline.Json.SetAsync("person:02", "$", new { name = "Joy", age = 25, city = "Los Angeles" });
+        _ = pipeline.Json.SetAsync("person:03", "$", new { name = "Mark", age = 21, city = "Chicago" });
+        _ = pipeline.Json.SetAsync("person:04", "$", new { name = "Steve", age = 24, city = "Phoenix" });
+        _ = pipeline.Json.SetAsync("person:05", "$", new { name = "Michael", age = 55, city = "San Antonio" });
 
         // Create the schema to index name as text field, age as a numeric field and city as tag field.
         var schema = new Schema().AddTextField("name").AddNumericField("age", true).AddTagField("city");
@@ -142,24 +143,26 @@ public void JsonWithSearchPipeline()
         var parameters = FTCreateParams.CreateParams().On(IndexDataType.JSON).Prefix("person:");
 
         // Create the index via pipeline
-        pipeline.Ft.CreateAsync("person-idx", parameters, schema);
-
-        // Search for all indexed person records
-        var getAllPersons = pipeline.Ft.SearchAsync("person-idx", new Query());
+        var create = pipeline.Ft.CreateAsync("person-idx", parameters, schema);
 
         // execute the pipeline
         pipeline.Execute();
 
+        // Search for all indexed person records
+        // Task.Delay(2000).Wait();
+        var getAllPersons = await db.FT().SearchAsync("person-idx", new Query());
+
+
         // Get the total count of people records that indexed.
-        var getAllPersonsResult = getAllPersons.Result;
-        var count = getAllPersonsResult.TotalResults;
+        var count = getAllPersons.TotalResults;
 
         // Gets the first person form the result.
-        var firstPerson = getAllPersonsResult.Documents.FirstOrDefault();
+        var firstPerson = getAllPersons.Documents.FirstOrDefault();
         // first person is John here.
 
+        Assert.True(create.Result);
         Assert.Equal(5, count);
-        Assert.Equal("person:01", firstPerson?.Id);
+        //Assert.Equal("person:01", firstPerson?.Id);
     }
 
     [Fact]

From ec67b4723253d9fff14f3c3b54a812dc85a46392 Mon Sep 17 00:00:00 2001
From: shacharPash <shachar.pashchur@redis.com>
Date: Sun, 5 Feb 2023 16:14:22 +0200
Subject: [PATCH 8/9] Add delay before search

---
 tests/NRedisStack.Tests/Examples/ExamplesTests.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index a680392c..e9489d91 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -149,7 +149,7 @@ public async Task JsonWithSearchPipeline()
         pipeline.Execute();
 
         // Search for all indexed person records
-        // Task.Delay(2000).Wait();
+        Task.Delay(2000).Wait();
         var getAllPersons = await db.FT().SearchAsync("person-idx", new Query());
 
 

From 0803d307d282c316d78f8b729fbb86f005da41d0 Mon Sep 17 00:00:00 2001
From: shacharPash <shachar.pashchur@redis.com>
Date: Sun, 5 Feb 2023 17:22:47 +0200
Subject: [PATCH 9/9] Change to one consractor for Pipeline that get IDatabase

---
 Examples/CombinationModulesPipeline.md        |  5 ++-
 Examples/PipelineExample.md                   | 40 +++++++++----------
 Examples/PipelineWithAsync.md                 |  2 +-
 src/NRedisStack/Pipeline.cs                   |  5 ---
 .../Examples/ExamplesTests.cs                 | 25 +++++-------
 tests/NRedisStack.Tests/PipelineTests.cs      |  8 ++--
 6 files changed, 36 insertions(+), 49 deletions(-)

diff --git a/Examples/CombinationModulesPipeline.md b/Examples/CombinationModulesPipeline.md
index 7224677d..d7f1bd66 100644
--- a/Examples/CombinationModulesPipeline.md
+++ b/Examples/CombinationModulesPipeline.md
@@ -8,7 +8,8 @@ var redis = ConnectionMultiplexer.Connect("localhost");
 
 Setup pipeline connection
 ```csharp
-var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+var db = redis.GetDatabase();
+var pipeline = new Pipeline(db);
 ```
 
 ## JSON
@@ -39,7 +40,7 @@ pipeline.Ft.CreateAsync("person-idx", parameters, schema);
 
 Search for all indexed person records
 ```csharp
-var getAllPersons = pipeline.Ft.SearchAsync("person-idx", new Query());
+var getAllPersons = db.FT().SearchAsync("person-idx", new Query());
 ```
 
 Execute the pipeline
diff --git a/Examples/PipelineExample.md b/Examples/PipelineExample.md
index 12e2fe9a..7a755600 100644
--- a/Examples/PipelineExample.md
+++ b/Examples/PipelineExample.md
@@ -1,56 +1,52 @@
 # Pipeline
 ## An example of pipelines Redis Stack Redis commands (JSON.SET & JSON.CLEAR & JSON.GET)
 
-Connect to the Redis server and Setup 2 Pipelines
-
-Pipeline can get IDatabase for pipeline1
+Connect to the Redis server and Setup new Pipeline
 ```csharp
 IDatabase db = redisFixture.Redis.GetDatabase();
-var pipeline1 = new Pipeline(db);
+var pipeline = new Pipeline(db);
 ```
 
-Pipeline can get IConnectionMultiplexer for pipeline2
-```csharp
-var redis = ConnectionMultiplexer.Connect("localhost");
-var pipeline2 = new Pipeline(redis);
-```
 
 Add JsonSet to pipeline
 ```csharp
-pipeline1.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
+pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 ```
 
 Increase age by 2
 ```csharp
-pipeline1.Json.NumIncrbyAsync("person", "$.age", 2);
-```
-
-Execute pipeline1
-```csharp
-pipeline1.Execute();
+pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
 ```
 
 Clear the nicknames from the Json
 ```csharp
-pipeline2.Json.ClearAsync("person", "$.nicknames");
+pipeline.Json.ClearAsync("person", "$.nicknames");
 ```
 
 Delete the nicknames
 ```csharp
-pipeline2.Json.DelAsync("person", "$.nicknames");
+pipeline.Json.DelAsync("person", "$.nicknames");
 ```
 
 Get the Json response
 ```csharp
-var getResponse = pipeline2.Json.GetAsync("person");
+var getResponse = pipeline.Json.GetAsync("person");
 ```
 
-Execute pipeline2
+Execute pipeline
 ```csharp
-pipeline2.Execute();
+pipeline.Execute();
 ```
 
 Get the result of getResponse
 ```csharp
 var result = getResponse.Result;
-```
\ No newline at end of file
+```
+now result is:
+```json
+{
+  "name": "John",
+  "age": 32,
+  "city": "New York"
+}
+```
diff --git a/Examples/PipelineWithAsync.md b/Examples/PipelineWithAsync.md
index 1385517f..86bd2464 100644
--- a/Examples/PipelineWithAsync.md
+++ b/Examples/PipelineWithAsync.md
@@ -13,7 +13,7 @@ var db = redis.GetDatabase();
 
 Setup pipeline connection
 ```csharp
-var pipeline = new Pipeline(redis);
+var pipeline = new Pipeline(db);
 ```
 
 Create metedata lables for time-series.
diff --git a/src/NRedisStack/Pipeline.cs b/src/NRedisStack/Pipeline.cs
index a9caecb2..53f7fc31 100644
--- a/src/NRedisStack/Pipeline.cs
+++ b/src/NRedisStack/Pipeline.cs
@@ -4,11 +4,6 @@ namespace NRedisStack;
 
 public class Pipeline
 {
-    public Pipeline(IConnectionMultiplexer muxer)
-    {
-        _batch = muxer.GetDatabase().CreateBatch();
-    }
-
     public Pipeline(IDatabase db)
     {
         _batch = db.CreateBatch();
diff --git a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
index e9489d91..c907694f 100644
--- a/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
+++ b/tests/NRedisStack.Tests/Examples/ExamplesTests.cs
@@ -83,35 +83,28 @@ public void PipelineExample()
     {
         // Connect to the Redis server and Setup 2 Pipelines
 
-        // Pipeline can get IDatabase for pipeline1
+        // Pipeline can get IDatabase for pipeline
         IDatabase db = redisFixture.Redis.GetDatabase();
         db.Execute("FLUSHALL");
-        var pipeline1 = new Pipeline(db);
-
-        // Pipeline can get IConnectionMultiplexer for pipeline2
-        var redis = ConnectionMultiplexer.Connect("localhost");
-        var pipeline2 = new Pipeline(redis);
+        var pipeline = new Pipeline(db);
 
         // Add JsonSet to pipeline
-        pipeline1.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
+        pipeline.Json.SetAsync("person", "$", new { name = "John", age = 30, city = "New York", nicknames = new[] { "John", "Johny", "Jo" } });
 
         // Increase age by 2
-        pipeline1.Json.NumIncrbyAsync("person", "$.age", 2);
-
-        // Execute the pipeline1
-        pipeline1.Execute();
+        pipeline.Json.NumIncrbyAsync("person", "$.age", 2);
 
         // Clear the nicknames from the Json
-        pipeline2.Json.ClearAsync("person", "$.nicknames");
+        pipeline.Json.ClearAsync("person", "$.nicknames");
 
         // Del the nicknames
-        pipeline2.Json.DelAsync("person", "$.nicknames");
+        pipeline.Json.DelAsync("person", "$.nicknames");
 
         // Get the Json response
-        var getResponse = pipeline2.Json.GetAsync("person");
+        var getResponse = pipeline.Json.GetAsync("person");
 
         // Execute the pipeline2
-        pipeline2.Execute();
+        pipeline.Execute();
 
         // Get the result back JSON
         var result = getResponse.Result;
@@ -175,7 +168,7 @@ public async Task PipelineWithAsync()
         var db = redis.GetDatabase();
         db.Execute("FLUSHALL");
         // Setup pipeline connection
-        var pipeline = new Pipeline(redis);
+        var pipeline = new Pipeline(db);
 
 
         // Create metedata lables for time-series.
diff --git a/tests/NRedisStack.Tests/PipelineTests.cs b/tests/NRedisStack.Tests/PipelineTests.cs
index a9948447..effe00c5 100644
--- a/tests/NRedisStack.Tests/PipelineTests.cs
+++ b/tests/NRedisStack.Tests/PipelineTests.cs
@@ -99,16 +99,18 @@ public async Task TestBloomPipeline()
     [Fact]
     public async Task TestJsonPipeline()
     {
-        var pipeline = new Pipeline(ConnectionMultiplexer.Connect("localhost"));
+        IDatabase db = redisFixture.Redis.GetDatabase();
+        var pipeline = new Pipeline(db);
         pipeline.Db.ExecuteAsync("FLUSHALL");
 
         string jsonPerson = JsonSerializer.Serialize(new Person { Name = "Shachar", Age = 23 });
-        var setResponse = pipeline.Json.SetAsync("key", "$", jsonPerson);
+        pipeline.Json.SetAsync("key", "$", jsonPerson);
+        // var setResponse = pipeline.Json.SetAsync("key", "$", jsonPerson);
         var getResponse = pipeline.Json.GetAsync("key");
 
         pipeline.Execute();
 
-        Assert.Equal("True", setResponse.Result.ToString());
+        // Assert.Equal("True", setResponse.Result.ToString());
         Assert.Equal("{\"Name\":\"Shachar\",\"Age\":23}", getResponse.Result.ToString());
     }
 }
\ No newline at end of file