ASYNC STREAM Archives

[C#/COMMON/.NET5] IAsyncEnumerable 인터페이스 : 비동기 스트림 취소하기

■ IAsyncEnumerable<T> 인터페이스를 사용해 비동기 스트림을 취소하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Collections.Generic;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync(token)

        /// <summary>
        /// 값 열거 가능형 구하기 (비동기)
        /// </summary>
        /// <param name="token">취소 토큰</param>
        /// <returns>값 열거 가능형</returns>
        private static async IAsyncEnumerable<int> GetValueEnumerableAsync([EnumeratorCancellation] CancellationToken token = default)
        {
            for(int i = 0; i < 10; i++)
            {
                await Task.Delay(i * 100, token);

                yield return i;
            }
        }

        #endregion
        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        /// <returns>태스크</returns>
        private static async Task Main()
        {
            using CancellationTokenSource source = new CancellationTokenSource(3000);

            CancellationToken token = source.Token;

            await foreach(int value in GetValueEnumerableAsync(token))
            {
                Console.WriteLine(value);
            }
        }

        #endregion
    }
}

using System;

using System.Collections.Generic;

using System.Runtime.CompilerServices;

using System.Threading;

using System.Threading.Tasks;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync(token)

/// <summary>

/// 값 열거 가능형 구하기 (비동기)

/// </summary>

/// <param name="token">취소 토큰</param>

/// <returns>값 열거 가능형</returns>

private static async IAsyncEnumerable<int> GetValueEnumerableAsync([EnumeratorCancellation] CancellationToken token = default)

{

for(int i = 0; i < 10; i++)

{

await Task.Delay(i * 100, token);

yield return i;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

using CancellationTokenSource source = new CancellationTokenSource(3000);

CancellationToken token = source.Token;

await foreach(int value in GetValueEnumerableAsync(token))

{

Console.WriteLine(value);

}

#endregion

}

TestProject.zip

[C#/COMMON/LINQ/.NET5] AsyncEnumerable 클래스 : CountAwaitAsync 확장 메소드를 사용해 비동기 열거 가능 시퀀스에서 조건을 충족하는 요소 수 구하기

■ AsyncEnumerable 클래스의 CountAwaitAsync 확장 메소드를 사용해 비동기 열거 가능 시퀀스에서 조건을 충족하는 요소 수를 구하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

        /// <summary>
        /// 값 열거 가능형 구하기 (비동기)
        /// </summary>
        /// <returns>값 열거 가능형</returns>
        private static async IAsyncEnumerable<int> GetValueEnumerableAsync()
        {
            for(int i = 0; i < 10; i++)
            {
                await Task.Delay(i * 100);

                yield return i;
            }
        }

        #endregion
        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        /// <returns>태스크</returns>
        private static async Task Main()
        {
            int count = await GetValueEnumerableAsync().CountAwaitAsync
            (
                async value =>
                {
                    await Task.Delay(10);

                    return value % 2 == 0;
                }
            );

            Console.WriteLine(count);
        }

        #endregion
    }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

/// <summary>

/// 값 열거 가능형 구하기 (비동기)

/// </summary>

/// <returns>값 열거 가능형</returns>

private static async IAsyncEnumerable<int> GetValueEnumerableAsync()

{

for(int i = 0; i < 10; i++)

{

await Task.Delay(i * 100);

yield return i;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

int count = await GetValueEnumerableAsync().CountAwaitAsync

(

async value =>

{

await Task.Delay(10);

return value % 2 == 0;

}

);

Console.WriteLine(count);

}

#endregion

}

TestProject.zip

[C#/COMMON/LINQ/.NET5] AsyncEnumerable 클래스 : CountAsync 확장 메소드를 사용해 비동기 열거 가능 시퀀스에서 조건을 충족하는 요소 수 구하기

■ AsyncEnumerable 클래스의 CountAsync 확장 메소드를 사용해 비동기 열거 가능 시퀀스에서 조건을 충족하는 요소 수를 구하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

        /// <summary>
        /// 값 열거 가능형 구하기 (비동기)
        /// </summary>
        /// <returns>값 열거 가능형</returns>
        private static async IAsyncEnumerable<int> GetValueEnumerableAsync()
        {
            for(int i = 0; i < 10; i++)
            {
                await Task.Delay(i * 100);

                yield return i;
            }
        }

        #endregion
        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        /// <returns>태스크</returns>
        private static async Task Main()
        {
            int count = await GetValueEnumerableAsync().CountAsync(value => value % 2 == 0);

            Console.WriteLine(count);
        }

        #endregion
    }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

/// <summary>

/// 값 열거 가능형 구하기 (비동기)

/// </summary>

/// <returns>값 열거 가능형</returns>

private static async IAsyncEnumerable<int> GetValueEnumerableAsync()

{

for(int i = 0; i < 10; i++)

{

await Task.Delay(i * 100);

yield return i;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

int count = await GetValueEnumerableAsync().CountAsync(value => value % 2 == 0);

Console.WriteLine(count);

}

#endregion

}

TestProject.zip

[C#/COMMON/LINQ/.NET5] AsyncEnumerable 클래스 : Where 확장 메소드를 사용해 동기 조건자 기반 비동기 열거 가능 시퀀스 필터링하기

■ AsyncEnumerable 클래스의 Where 확장 메소드를 사용해 동기 조건자 기반 비동기 열거 가능 시퀀스를 필터링하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

        /// <summary>
        /// 값 열거 가능형 구하기 (비동기)
        /// </summary>
        /// <returns>값 열거 가능형</returns>
        private static async IAsyncEnumerable<int> GetValueEnumerableAsync()
        {
            for(int i = 0; i < 10; i++)
            {
                await Task.Delay(i * 100);

                yield return i;
            }
        }

        #endregion
        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        /// <returns>태스크</returns>
        private static async Task Main()
        {
            IAsyncEnumerable<int> valueEnumerable = GetValueEnumerableAsync().Where(value => value % 2 == 0);

            await foreach(int value in valueEnumerable)
            {
                Console.WriteLine(value);
            }
        }

        #endregion
    }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

/// <summary>

/// 값 열거 가능형 구하기 (비동기)

/// </summary>

/// <returns>값 열거 가능형</returns>

private static async IAsyncEnumerable<int> GetValueEnumerableAsync()

{

for(int i = 0; i < 10; i++)

{

await Task.Delay(i * 100);

yield return i;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

IAsyncEnumerable<int> valueEnumerable = GetValueEnumerableAsync().Where(value => value % 2 == 0);

await foreach(int value in valueEnumerable)

{

Console.WriteLine(value);

}

#endregion

}

TestProject.zip

[C#/COMMON/LINQ/.NET5] AsyncEnumerable 클래스 : WhereAwait 확장 메소드를 사용해 비동기 조건자 기반 비동기 열거 가능 시퀀스 필터링하기

■ AsyncEnumerable 클래스의 WhereAwait 확장 메소드를 사용해 비동기 조건자 기반 비동기 열거 가능 시퀀스를 필터링하는 방법을 보여준다. ▶ Program.cs


using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

        /// <summary>
        /// 값 열거 가능형 구하기 (비동기)
        /// </summary>
        /// <returns>값 열거 가능형</returns>
        private static async IAsyncEnumerable<int> GetValueEnumerableAsync()
        {
            for(int i = 0; i < 10; i++)
            {
                await Task.Delay(i * 100);

                yield return i;
            }
        }

        #endregion
        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        /// <returns>태스크</returns>
        private static async Task Main()
        {
            IAsyncEnumerable<int> valueEnumerable = GetValueEnumerableAsync().WhereAwait
            (
                async value =>
                {
                    await Task.Delay(10);

                    return value % 2 == 0;
                }
            );

            await foreach(int value in valueEnumerable)
            {
                Console.WriteLine(value);
            }
        }

        #endregion
    }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 값 열거 가능형 구하기 (비동기) - GetValueEnumerableAsync()

/// <summary>

/// 값 열거 가능형 구하기 (비동기)

/// </summary>

/// <returns>값 열거 가능형</returns>

private static async IAsyncEnumerable<int> GetValueEnumerableAsync()

{

for(int i = 0; i < 10; i++)

{

await Task.Delay(i * 100);

yield return i;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

IAsyncEnumerable<int> valueEnumerable = GetValueEnumerableAsync().WhereAwait

(

async value =>

{

await Task.Delay(10);

return value % 2 == 0;

}

);

await foreach(int value in valueEnumerable)

{

Console.WriteLine(value);

}

#endregion

}

TestProject.zip

[C#/COMMON/.NET5] IAsyncEnumerable 인터페이스 : 넥서스 저장소(Nexus Repository)에서 자산(Asset) 정보 구하기

■ IAsyncEnumerable<T> 인터페이스를 사용해 넥서스 저장소(Nexus Repository)에서 자산(Asset) 정보를 구하는 방법을 보여준다. ▶ Checksum.cs


using Newtonsoft.Json;

namespace TestProject
{
    /// <summary>
    /// 체크썸
    /// </summary>
    public class Checksum
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region MD5 - MD5

        /// <summary>
        /// MD5
        /// </summary>
        [JsonProperty("md5")]
        public string MD5 { get; set; }

        #endregion
        #region SHA1 - SHA1

        /// <summary>
        /// SHA1
        /// </summary>
        [JsonProperty("sha1")]
        public string SHA1 { get; set; }

        #endregion
        #region SHA256 - SHA256

        /// <summary>
        /// SHA256
        /// </summary>
        [JsonProperty("sha256")]
        public string SHA256 { get; set; }

        #endregion
        #region SHA512 - SHA512

        /// <summary>
        /// SHA512
        /// </summary>
        [JsonProperty("sha512")]
        public string SHA512 { get; set; }

        #endregion
    }
}

using Newtonsoft.Json;

namespace TestProject

{

/// <summary>

/// 체크썸

/// </summary>

public class Checksum

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region MD5 - MD5

/// <summary>

/// MD5

/// </summary>

[JsonProperty("md5")]

public string MD5 { get; set; }

#endregion

#region SHA1 - SHA1

/// <summary>

/// SHA1

/// </summary>

[JsonProperty("sha1")]

public string SHA1 { get; set; }

#endregion

#region SHA256 - SHA256

/// <summary>

/// SHA256

/// </summary>

[JsonProperty("sha256")]

public string SHA256 { get; set; }

#endregion

#region SHA512 - SHA512

/// <summary>

/// SHA512

/// </summary>

[JsonProperty("sha512")]

public string SHA512 { get; set; }

#endregion

}

▶ Item.cs


using Newtonsoft.Json;

namespace TestProject
{
    /// <summary>
    /// 항목
    /// </summary>
    public class Item
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID

        /// <summary>
        /// ID
        /// </summary>
        [JsonProperty("id")]
        public string ID { get; set; }

        #endregion
        #region 저장소 - Repository

        /// <summary>
        /// 저장소
        /// </summary>
        [JsonProperty("repository")]
        public string Repository { get; set; }

        #endregion
        #region 경로 - Path

        /// <summary>
        /// 경로
        /// </summary>
        [JsonProperty("path")]
        public string Path { get; set; }

        #endregion
        #region 포맷 - Format

        /// <summary>
        /// 포맷
        /// </summary>
        [JsonProperty("format")]
        public string Format { get; set; }

        #endregion
        #region 다운로드 URL - DownloadURL

        /// <summary>
        /// 다운로드 URL
        /// </summary>
        [JsonProperty("downloadUrl")]
        public string DownloadURL { get; set; }

        #endregion
        #region 체크썸 - Checksum

        /// <summary>
        /// 체크썸
        /// </summary>
        [JsonProperty("checksum")]
        public Checksum Checksum { get; set; }

        #endregion
    }
}

using Newtonsoft.Json;

namespace TestProject

{

/// <summary>

/// 항목

/// </summary>

public class Item

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

[JsonProperty("id")]

public string ID { get; set; }

#endregion

#region 저장소 - Repository

/// <summary>

/// 저장소

/// </summary>

[JsonProperty("repository")]

public string Repository { get; set; }

#endregion

#region 경로 - Path

/// <summary>

/// 경로

/// </summary>

[JsonProperty("path")]

public string Path { get; set; }

#endregion

#region 포맷 - Format

/// <summary>

/// 포맷

/// </summary>

[JsonProperty("format")]

public string Format { get; set; }

#endregion

#region 다운로드 URL - DownloadURL

/// <summary>

/// 다운로드 URL

/// </summary>

[JsonProperty("downloadUrl")]

public string DownloadURL { get; set; }

#endregion

#region 체크썸 - Checksum

/// <summary>

/// 체크썸

/// </summary>

[JsonProperty("checksum")]

public Checksum Checksum { get; set; }

#endregion

}

▶ AssetData.cs


using System.Collections.Generic;

using Newtonsoft.Json;

namespace TestProject
{
    /// <summary>
    /// 자산 데이터
    /// </summary>
    public class AssetData
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 항목 리스트 - ItemList

        /// <summary>
        /// 항목 리스트
        /// </summary>
        [JsonProperty("items")]
        public IList<Item> ItemList { get; set; }

        #endregion
        #region 연속 토큰 - ContinuationToken

        /// <summary>
        /// 연속 토큰
        /// </summary>
        [JsonProperty("continuationToken")]
        public string ContinuationToken { get; set; }

        #endregion
    }
}

using System.Collections.Generic;

using Newtonsoft.Json;

namespace TestProject

{

/// <summary>

/// 자산 데이터

/// </summary>

public class AssetData

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 항목 리스트 - ItemList

/// <summary>

/// 항목 리스트

/// </summary>

[JsonProperty("items")]

public IList<Item> ItemList { get; set; }

#endregion

#region 연속 토큰 - ContinuationToken

/// <summary>

/// 연속 토큰

/// </summary>

[JsonProperty("continuationToken")]

public string ContinuationToken { get; set; }

#endregion

}

▶

[C#/COMMON/.NET5] IAsyncEnumerable 인터페이스 : 비동기 스트림 만들기

■ IAsyncEnumerable<T> 인터페이스를 사용해 비동기 스트림을 만드는 방법을 보여준다. ▶ Program.cs


using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 난수기
        /// </summary>
        private static Random _random;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            _random = new Random(DateTime.Now.Millisecond);

            WriteTemperatureDataAsync().Wait();
        }

        #endregion
        #region 온도 수신하기 (비동기) - ReceiveTemperatureAsync()

        /// <summary>
        /// 온도 수신하기 (비동기)
        /// </summary>
        /// <returns>온도 태스크</returns>
        private static Task<int> ReceiveTemperatureAsync()
        {
            int sleep = _random.Next(100, 1000);

            Task.Delay(TimeSpan.FromMilliseconds(sleep)).Wait();

            Task<int> task = new Task<int>
            (
                () =>
                {
                    return _random.Next(0, 300);
                }
            );

            task.Start();

            return task;
        }

        #endregion
        #region 온도 데이터 수신하기 (비동기) - ReceiveTemperatureDataAsync()

        /// <summary>
        /// 온도 데이터 수신하기 (비동기)
        /// </summary>
        /// <returns>온도 비동기 열거 가능형</returns>
        private static async IAsyncEnumerable<int> ReceiveTemperatureDataAsync()
        {
            for(int i = 0; i < 20; i++)
            {
                int temperature = await ReceiveTemperatureAsync();

                yield return temperature;
            }
        }

        #endregion
        #region 온도 데이터 쓰기 (비동기) - WriteTemperatureDataAsync()

        /// <summary>
        /// 온도 데이터 쓰기 (비동기)
        /// </summary>
        /// <returns>태스크</returns>
        private static async Task WriteTemperatureDataAsync()
        {
            await foreach(int temperature in ReceiveTemperatureDataAsync())
            {
                Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} : {temperature}");
            }
        }

        #endregion
    }
}

100

101

102

103

using System;

using System.Collections.Generic;

using System.Threading.Tasks;

namespace TestProject

{

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 난수기

/// </summary>

private static Random _random;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

_random = new Random(DateTime.Now.Millisecond);

WriteTemperatureDataAsync().Wait();

}

#endregion

#region 온도 수신하기 (비동기) - ReceiveTemperatureAsync()

/// <summary>

/// 온도 수신하기 (비동기)

/// </summary>

/// <returns>온도 태스크</returns>

private static Task<int> ReceiveTemperatureAsync()

{

int sleep = _random.Next(100, 1000);

Task.Delay(TimeSpan.FromMilliseconds(sleep)).Wait();

Task<int> task = new Task<int>

(

() =>

{

return _random.Next(0, 300);

}

);

task.Start();

return task;

}

#endregion

#region 온도 데이터 수신하기 (비동기) - ReceiveTemperatureDataAsync()

/// <summary>

/// 온도 데이터 수신하기 (비동기)

/// </summary>

/// <returns>온도 비동기 열거 가능형</returns>

private static async IAsyncEnumerable<int> ReceiveTemperatureDataAsync()

{

for(int i = 0; i < 20; i++)

{

int temperature = await ReceiveTemperatureAsync();

yield return temperature;

}

#endregion

#region 온도 데이터 쓰기 (비동기) - WriteTemperatureDataAsync()

/// <summary>

/// 온도 데이터 쓰기 (비동기)

/// </summary>

/// <returns>태스크</returns>

private static async Task WriteTemperatureDataAsync()

{

await foreach(int temperature in ReceiveTemperatureDataAsync())

{

Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} : {temperature}");

}

#endregion

}

TestProject.zip