.

Author: Ledjon Behluli

samples/02_HelloWorld/Program.cs

@@ -32,7 +32,7 @@
     {
         Console.WriteLine($"THREAD 1: Searching for matching tuple with template: {template}");
 
-        var helloWorldTuple = await agent.Peek(template);
+        var helloWorldTuple = await agent.PeekAsync(template);
         if (!helloWorldTuple.IsEmpty)
         {
             Console.WriteLine($"THREAD 1: Found this tuple: {helloWorldTuple}");
@@ -50,7 +50,7 @@
 
     while (true)
     {
-        var helloTuple = await agent.Peek(template);
+        var helloTuple = await agent.PeekAsync(template);
         if (!helloTuple.IsEmpty)
         {
             Console.WriteLine($"THREAD 2: Found this tuple: {helloTuple}");

samples/03_Concurrent/Program.cs

@@ -33,7 +33,7 @@ await Task.WhenAll(CreateTasks(100, async index =>
 
 await Task.WhenAll(CreateTasks(100, async index =>
 {
-    SpaceTuple tuple = await agent.Peek(new(EXCHANGE_KEY, index));
+    SpaceTuple tuple = await agent.PeekAsync(new(EXCHANGE_KEY, index));
     Console.WriteLine($"READER {index}: {tuple}");
 }));
 

samples/04_DelayedExec/Evaluator/Program.cs

@@ -51,7 +51,7 @@ await agent.EvaluateAsync(async () =>
     await Task.Delay(500);
 }
 
-Console.WriteLine($"WORKER: Result from evaluation: {await agent.Peek(new(EXCHANGE_KEY, typeof(double)))}");
+Console.WriteLine($"WORKER: Result from evaluation: {await agent.PeekAsync(new(EXCHANGE_KEY, typeof(double)))}");
 
 Console.WriteLine("\nPress any key to terminate...");
 Console.ReadKey();

samples/04_DelayedExec/Peeker/Program.cs

@@ -56,7 +56,7 @@ await agent.PeekAsync(template, async tuple =>
     await Task.Delay(100);
 }
 
-Console.WriteLine($"WORKER: Checking if {tuple} is still in space: {!(await agent.Peek(template)).IsEmpty}");
+Console.WriteLine($"WORKER: Checking if {tuple} is still in space: {!(await agent.PeekAsync(template)).IsEmpty}");
 
 Console.WriteLine("\nPress any key to terminate...");
 Console.ReadKey();

samples/04_DelayedExec/Poper/Program.cs

@@ -56,7 +56,7 @@ await agent.PopAsync(template, async tuple =>
     await Task.Delay(100);
 }
 
-Console.WriteLine($"WORKER: Checking if {tuple} is still in space: {!(await agent.Peek(template)).IsEmpty}");
+Console.WriteLine($"WORKER: Checking if {tuple} is still in space: {!(await agent.PeekAsync(template)).IsEmpty}");
 
 
 Console.WriteLine("\nPress any key to terminate...");

samples/07_ClientServer/Client/Program.cs

@@ -36,7 +36,7 @@
     await agent.WriteAsync(clientTuple);
     Console.WriteLine($"WRITE: {clientTuple}");
 
-    SpaceTuple serverTuple = await agent.Peek(new("SERVER"));
+    SpaceTuple serverTuple = await agent.PeekAsync(new("SERVER"));
     if (!serverTuple.IsEmpty)
     {
         Console.WriteLine($"READ: {serverTuple}");

samples/07_ClientServer/Server/Program.cs

@@ -35,7 +35,7 @@
     await agent.WriteAsync(serverTuple);
     Console.WriteLine($"WRITE: {serverTuple}");
 
-    SpaceTuple clientTuple = await agent.Peek(new("CLIENT"));
+    SpaceTuple clientTuple = await agent.PeekAsync(new("CLIENT"));
     if (!clientTuple.IsEmpty)
     {
         Console.WriteLine($"READ: {clientTuple}");

samples/Sandbox/Program.cs

@@ -16,6 +16,11 @@
 
 Console.WriteLine("Connected to the tuple space.\n\n");
 
+var agent = host.Services.GetService<ISpaceAgent>();
+
+var a = await agent.ScanAsync(new(1, 1));
+
+
 // test anything here...
 
 Console.WriteLine("\nPress any key to terminate...\n");

src/OrleanSpaces/Agents/SpaceAgent.cs

@@ -100,7 +100,7 @@ public ValueTask EvaluateAsync(Func<Task<SpaceTuple>> evaluation)
         return evaluationChannel.Writer.WriteAsync(evaluation);
     }
 
-    public ValueTask<SpaceTuple> Peek(SpaceTemplate template)
+    public ValueTask<SpaceTuple> PeekAsync(SpaceTemplate template)
     {
         var tuple = tuples.FirstOrDefault(x => template.Matches(x.Tuple));
         return new(tuple.Tuple);

src/OrleanSpaces/ISpaceAgent.cs

@@ -52,7 +52,7 @@ public interface ISpaceAgent
     /// </summary>
     /// <param name="template">A template that potentially matches a <see cref="SpaceTuple"/>.</param>
     /// <returns><see cref="SpaceTuple"/> (potentially one with zero length).</returns>
-    ValueTask<SpaceTuple> Peek(SpaceTemplate template);
+    ValueTask<SpaceTuple> PeekAsync(SpaceTemplate template);
 
     /// <summary>
     /// Reads a <see cref="SpaceTuple"/> that is potentially matched by the given <paramref name="template"/>.
@@ -63,7 +63,7 @@ public interface ISpaceAgent
     /// </summary>
     /// <param name="template">A template that potentially matches a <see cref="SpaceTuple"/>.</param>
     /// <param name="callback">A callback function that will be executed, with the <see cref="SpaceTuple"/> as the argument.</param>
-    /// <remarks><i>Same as with <see cref="Peek(SpaceTemplate)"/>, the original tuple is <u>kept</u> in the space once <paramref name="callback"/> gets invoked.</i></remarks>
+    /// <remarks><i>Same as with <see cref="PeekAsync(SpaceTemplate)"/>, the original tuple is <u>kept</u> in the space once <paramref name="callback"/> gets invoked.</i></remarks>
     ValueTask PeekAsync(SpaceTemplate template, Func<SpaceTuple, Task> callback);
 
     /// <summary>
@@ -98,7 +98,7 @@ public interface ISpaceAgent
     /// Reads multiple <see cref="SpaceTuple"/>'s that are potentially matched by the given <paramref name="template"/>.
     /// </summary>
     /// <param name="template">A template that potentially matches multiple <see cref="SpaceTuple"/>'s.</param>
-    /// <remarks><i>Same as with <see cref="Peek(SpaceTemplate)"/>, the original tuple's are <u>kept</u> in the space.</i></remarks>
+    /// <remarks><i>Same as with <see cref="PeekAsync(SpaceTemplate)"/>, the original tuple's are <u>kept</u> in the space.</i></remarks>
     ValueTask<IEnumerable<SpaceTuple>> ScanAsync(SpaceTemplate template);
 
     /// <summary>