ppi/queryableContains

PierrePicard20 · PierrePicard20 · commit 119c97fa63bd · 2026-01-22T16:40:43.000+01:00
diff --git a/ArmoniK.Extension.CSharp.Client/Handles/SessionHandle.cs b/ArmoniK.Extension.CSharp.Client/Handles/SessionHandle.cs
@@ -435,7 +435,7 @@ private async Task RunAsync()
                                                                                          SingleReader = true,
                                                                                          SingleWriter = true,
                                                                                        });
-      var channelReveiverTask = channel.Reader.ToAsyncEnumerable(callbacksCts_.Token)
+      var channelReceiverTask = channel.Reader.ToAsyncEnumerable(callbacksCts_.Token)
                                        .ParallelForEach(new ParallelTaskOptions
                                                         {
                                                           ParallelismLimit  = client_.Properties.ParallelismLimit,
@@ -514,7 +514,7 @@ await Task.Delay(5000,
 
       try
       {
-        await channelReveiverTask.ConfigureAwait(false);
+        await channelReceiverTask.ConfigureAwait(false);
       }
       catch (OperationCanceledException) when (loopCts_.Token.IsCancellationRequested)
       {

Original file line number	Diff line number	Diff line change
`@@ -435,7 +435,7 @@ private async Task RunAsync()`
`435`	`435`	`SingleReader = true,`
`436`	`436`	`SingleWriter = true,`
`437`	`437`	`});`
`438`		`- var channelReveiverTask = channel.Reader.ToAsyncEnumerable(callbacksCts_.Token)`
	`438`	`+ var channelReceiverTask = channel.Reader.ToAsyncEnumerable(callbacksCts_.Token)`
`439`	`439`	`.ParallelForEach(new ParallelTaskOptions`
`440`	`440`	`{`
`441`	`441`	`ParallelismLimit = client_.Properties.ParallelismLimit,`
`@@ -514,7 +514,7 @@ await Task.Delay(5000,`
`514`	`514`
`515`	`515`	`try`
`516`	`516`	`{`
`517`		`- await channelReveiverTask.ConfigureAwait(false);`
	`517`	`+ await channelReceiverTask.ConfigureAwait(false);`
`518`	`518`	`}`
`519`	`519`	`catch (OperationCanceledException) when (loopCts_.Token.IsCancellationRequested)`
`520`	`520`	`{`