Async Streams (csharp-8)

Author: ibrahimatay

AsynchronousStreams/AsynchronousStreams.csproj

@@ -0,0 +1,8 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>netcoreapp3.1</TargetFramework>
+    </PropertyGroup>
+
+</Project>

AsynchronousStreams/Program.cs

@@ -0,0 +1,36 @@
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Runtime.CompilerServices;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace AsynchronousStreams
+{
+    /// <summary>
+    /// Async Streams
+    /// https://blog.jetbrains.com/dotnet/2019/09/16/async-streams-look-new-language-features-c-8/
+    /// https://docs.microsoft.com/en-us/dotnet/csharp/tutorials/generate-consume-asynchronous-stream
+    /// </summary>
+    class Program
+    {
+        static async Task Main(string[] args)
+        {
+            var cancellationToken = new CancellationTokenSource(millisecondsDelay: 1000);
+            await foreach (var result in GetTopSearchResults("dotnet").WithCancellation(cancellationToken.Token))
+            {
+                Console.WriteLine(result);
+            }
+        }
+        
+        static async IAsyncEnumerable<string> GetTopSearchResults(string term, [EnumeratorCancellation]CancellationToken token = default)
+        {
+            while (!token.IsCancellationRequested)
+            {
+                using var client = new HttpClient();
+                yield return await client.GetStringAsync($"https://www.google.com?q={term}");
+                yield return await client.GetStringAsync($"https://www.bing.com?q={term}"); 
+            }
+        }
+    }
+}

CsharpLangExamples.sln

@@ -8,6 +8,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "NumericLiteralSyntaxImprove
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "TupleTypes", "TupleTypes\TupleTypes.csproj", "{8258CFCE-03B8-4EB0-AF78-EAA7F88F4227}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "AsynchronousStreams", "AsynchronousStreams\AsynchronousStreams.csproj", "{4B90F64C-6005-45C4-86A0-DDCFD702D780}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -30,5 +32,9 @@ Global
 		{8258CFCE-03B8-4EB0-AF78-EAA7F88F4227}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{8258CFCE-03B8-4EB0-AF78-EAA7F88F4227}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{8258CFCE-03B8-4EB0-AF78-EAA7F88F4227}.Release|Any CPU.Build.0 = Release|Any CPU
+		{4B90F64C-6005-45C4-86A0-DDCFD702D780}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{4B90F64C-6005-45C4-86A0-DDCFD702D780}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{4B90F64C-6005-45C4-86A0-DDCFD702D780}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{4B90F64C-6005-45C4-86A0-DDCFD702D780}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 EndGlobal