Merge pull request #41 from open-olive/SIDE-1091

[SIDE-1091] Add support for IAsyncEnumerable

Author: richseviora

ldk/csharp/OliveHelpsLDK/Example/Program.cs

@@ -65,11 +65,10 @@ private void ClipboardStream()
             _clipboardStream = _services.Clipboard.Stream();
             Task.Run(async () =>
             {
-                while (await _clipboardStream.MoveNext())
+                await foreach (var clipboardContent in _clipboardStream.ToAsyncEnumerable())
                 {
                     try
                     {
-                        var clipboardContent = _clipboardStream.Current();
                         Logger.Info($"Received Clipboard Update \"{clipboardContent}\"");
                         switch (clipboardContent)
                         {

ldk/csharp/OliveHelpsLDK/OliveHelpsLDK/IStreamingCall.cs

@@ -1,4 +1,6 @@
 using System;
+using System.Collections.Generic;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace OliveHelpsLDK
@@ -8,5 +10,7 @@ public interface IStreamingCall<TOutput> : IDisposable
         TOutput Current();
 
         Task<bool> MoveNext();
+
+        IAsyncEnumerable<TOutput> ToAsyncEnumerable(CancellationToken cancellationToken = default);
     }
 }

ldk/csharp/OliveHelpsLDK/OliveHelpsLDK/OliveHelpsLDK.csproj

@@ -7,9 +7,10 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Google.Protobuf" Version="3.13.0" />
-        <PackageReference Include="Grpc" Version="2.33.1" />
-        <PackageReference Include="Grpc.Tools" Version="2.33.1">
+        <PackageReference Include="Google.Protobuf" Version="3.13.0"/>
+        <PackageReference Include="Grpc" Version="2.34.0"/>
+        <PackageReference Include="Grpc.Net.Common" Version="2.34.0"/>
+        <PackageReference Include="Grpc.Tools" Version="2.34.0">
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>

ldk/csharp/OliveHelpsLDK/OliveHelpsLDK/StreamingCall.cs

@@ -1,4 +1,7 @@
 using System;
+using System.Collections.Generic;
+using System.Runtime.CompilerServices;
+using System.Threading;
 using System.Threading.Tasks;
 using Grpc.Core;
 
@@ -30,5 +33,14 @@ public Task<bool> MoveNext()
         {
             return _call.ResponseStream.MoveNext();
         }
+
+        public async IAsyncEnumerable<TOutput> ToAsyncEnumerable(
+            [EnumeratorCancellation] CancellationToken cancellationToken = default)
+        {
+            await foreach (var output in _call.ResponseStream.ReadAllAsync(cancellationToken).ConfigureAwait(false))
+            {
+                yield return _transformer(output);
+            }
+        }
     }
 }