Async streams with IAsyncEnumerable in C Sharp (C#) - Step-by-Step Execution

Concept Flow - Async streams with IAsyncEnumerable

Start async method

↓

Yield value asynchronously

↓

Caller awaits next value

↓

Repeat yield until done

↓

End async stream

↓

Caller finishes iteration

The async method produces values one by one asynchronously, and the caller awaits each value before continuing.

Execution Sample

C Sharp (C#)

async IAsyncEnumerable<int> CountAsync()
{
    for (int i = 1; i <= 3; i++)
    {
        await Task.Delay(1000);
        yield return i;
    }
}

This async stream method yields numbers 1 to 3 with a 1-second delay between each.

Execution Table

Step	i value	Action	Yielded Value	Caller awaits
1	1	Start loop, delay 1s		Caller waits for value
2	1	Yield return 1	1	Caller receives 1
3	2	Start next loop, delay 1s		Caller waits for next value
4	2	Yield return 2	2	Caller receives 2
5	3	Start next loop, delay 1s		Caller waits for next value
6	3	Yield return 3	3	Caller receives 3
7	4	Loop ends (i=4 > 3)		Caller finishes iteration

💡 Loop ends when i becomes 4, which is greater than 3, so async stream completes.

Variable Tracker

Variable	Start	After 1	After 2	After 3	Final
i	0	1	2	3	4

Key Moments - 3 Insights

Why does the caller wait after each yield return?

Because the method yields values asynchronously, the caller must await each value before continuing, as shown in steps 2, 4, and 6 of the execution table.

What happens when the loop condition fails?

When i becomes 4, which is greater than 3, the loop ends and the async stream completes, as shown in step 7 of the execution table.

Why is Task.Delay used before yield return?

Task.Delay simulates asynchronous work or waiting, so the method pauses before yielding each value, making the stream truly asynchronous (see steps 1, 3, and 5).

Visual Quiz - 3 Questions

Look at the execution table, what value is yielded at step 4?

A 1

B 2

C 3

D No value yielded

💡 Hint

Check the 'Yielded Value' column at step 4 in the execution table.

At which step does the async stream complete?

A Step 6

B Step 7

C Step 3

D Step 1

💡 Hint

Look for the step where the loop ends and the caller finishes iteration in the execution table.

If Task.Delay was removed, how would the execution table change?

A Caller would not wait between yields

B Values would be yielded in reverse order

C Loop would run infinitely

D No values would be yielded

💡 Hint

Task.Delay causes the caller to wait; removing it means no delay between yields (see Action and Caller awaits columns).

Concept Snapshot

Async streams use IAsyncEnumerable<T> to produce values asynchronously.
Use 'yield return' with 'await' inside an async method.
Caller uses 'await foreach' to consume values one by one.
Each value is awaited before next is produced.
Useful for streaming data or asynchronous sequences.

Full Transcript

This example shows an async method CountAsync that yields numbers 1 to 3 with a 1-second delay before each yield. The execution table traces each step: starting the loop, delaying, yielding a value, and the caller awaiting that value. Variables like 'i' change from 0 to 4 as the loop progresses. Key moments clarify why the caller waits after each yield, what happens when the loop ends, and why Task.Delay is used. The visual quiz tests understanding of yielded values, completion step, and effect of removing delay. Async streams let you produce data asynchronously, making it easy to handle sequences that take time to generate.

Practice

1. What is the main purpose of using IAsyncEnumerable<T> in C#?

easy

A. To improve performance by using multiple threads automatically.

B. To create synchronous collections that support LINQ queries.

C. To handle exceptions in synchronous methods.

D. To asynchronously stream data one item at a time without blocking.

Solution

1. Step 1: Understand async streams concept

   IAsyncEnumerable<T> allows data to be produced and consumed asynchronously, item by item.

2. Step 2: Compare with other options

   Options B, C, and D describe synchronous collections, exception handling, or threading, which are not the main purpose of IAsyncEnumerable<T>.

3. Final Answer:

   To asynchronously stream data one item at a time without blocking. -> Option D

4. Quick Check:

   Async streams = async item-by-item data [OK]

Hint: Async streams deliver data piecewise without blocking [OK]

Common Mistakes:

• Confusing async streams with synchronous collections
• Thinking it automatically uses multiple threads
• Believing it handles exceptions directly

2. Which of the following is the correct syntax to consume an async stream named GetNumbersAsync()?

easy

A. foreach (var num in GetNumbersAsync()) { Console.WriteLine(num); }

B. await foreach (var num in GetNumbersAsync()) { Console.WriteLine(num); }

C. for await (var num in GetNumbersAsync()) { Console.WriteLine(num); }

D. async foreach (var num in GetNumbersAsync()) { Console.WriteLine(num); }

Solution

1. Step 1: Recall async stream consumption syntax

   To consume IAsyncEnumerable<T>, use await foreach to await each item asynchronously.

2. Step 2: Check each option

   foreach (var num in GetNumbersAsync()) { Console.WriteLine(num); } misses await, so it won't compile. for await (var num in GetNumbersAsync()) { Console.WriteLine(num); } uses invalid syntax for await. async foreach (var num in GetNumbersAsync()) { Console.WriteLine(num); } uses invalid keyword async foreach.

3. Final Answer:

   await foreach (var num in GetNumbersAsync()) { Console.WriteLine(num); } -> Option B

4. Quick Check:

   Use await foreach to read async streams [OK]

Hint: Always use 'await foreach' to read IAsyncEnumerable streams [OK]

Common Mistakes:

• Omitting 'await' before foreach
• Using 'for await' instead of 'await foreach'
• Writing 'async foreach' which is invalid

3. What will be the output of the following code?

async IAsyncEnumerable<int> GetNumbers()
{
    for (int i = 1; i <= 3; i++)
    {
        await Task.Delay(10);
        yield return i;
    }
}

async Task Run()
{
    await foreach (var n in GetNumbers())
    {
        Console.Write(n);
    }
}

Run().GetAwaiter().GetResult();

medium

A. No output

B. 1 2 3

C. 123

D. Task not awaited error

Solution

1. Step 1: Understand the async stream generation

   The method yields numbers 1, 2, 3 with a small delay between each.

2. Step 2: Analyze the output in Run()

   The await foreach prints each number without spaces or newlines, so output is "123".

3. Final Answer:

   123 -> Option C

4. Quick Check:

   Yielded numbers print consecutively as '123' [OK]

Hint: Yielded async items print in order without spaces by default [OK]

Common Mistakes:

• Expecting spaces between numbers
• Thinking the delay prevents output
• Assuming an error due to async usage

4. Identify the error in this async stream method:

async IAsyncEnumerable<int> CountToThree()
{
    for (int i = 1; i <= 3; i++)
    {
        Task.Delay(10);
        yield return i;
    }
}

medium

A. Missing await before Task.Delay(10);

B. Cannot use yield return in async methods

C. Return type should be Task<IAsyncEnumerable<int>>

D. for loop syntax is incorrect

Solution

1. Step 1: Check async delay usage

   Task.Delay(10) returns a task but is not awaited, so delay does not pause execution.

2. Step 2: Validate yield return in async streams

   Using yield return in async IAsyncEnumerable<T> is valid, so Cannot use yield return in async methods is wrong.

3. Final Answer:

   Missing await before Task.Delay(10); -> Option A

4. Quick Check:

   Await async calls inside async streams [OK]

Hint: Always await async calls like Task.Delay inside async streams [OK]

Common Mistakes:

• Forgetting to await Task.Delay
• Thinking yield return is invalid in async streams
• Confusing return type with Task<IAsyncEnumerable>

5. You want to create an async stream that yields only even numbers from 1 to 10 with a small delay between each yield. Which implementation correctly does this?

hard

A. async IAsyncEnumerable<int> EvenNumbers()
{
for (int i = 2; i <= 10; i += 2)
{
await Task.Delay(10);
yield return i;
}
}

B. async IAsyncEnumerable<int> EvenNumbers()
{
for (int i = 1; i <= 10; i++)
{
if (i % 2 == 0)
yield return i;
}
}

C. IAsyncEnumerable<int> EvenNumbers()
{
for (int i = 2; i <= 10; i += 2)
yield return i;
}

D. async Task<IAsyncEnumerable<int>> EvenNumbers()
{
for (int i = 2; i <= 10; i += 2)
yield return i;
}

Solution

1. Step 1: Check async stream signature and yield

   Async streams must be declared as async IAsyncEnumerable<T> and use yield return inside.

2. Step 2: Validate each option

   async IAsyncEnumerable<int> EvenNumbers() { for (int i = 1; i <= 10; i++) { if (i % 2 == 0) yield return i; } } lacks an async delay, so it is incomplete. async IAsyncEnumerable<int> EvenNumbers() { for (int i = 2; i <= 10; i += 2) { await Task.Delay(10); yield return i; } } correctly uses async IAsyncEnumerable<int>, awaits delay, and yields even numbers. IAsyncEnumerable<int> EvenNumbers() { for (int i = 2; i <= 10; i += 2) yield return i; } is missing async and await, so not an async stream. async Task<IAsyncEnumerable<int>> EvenNumbers() { for (int i = 2; i <= 10; i += 2) yield return i; } returns Task<IAsyncEnumerable> which is incorrect for async streams.

3. Final Answer:

   async IAsyncEnumerable<int> EvenNumbers() { for (int i = 2; i <= 10; i += 2) { await Task.Delay(10); yield return i; } } -> Option A

4. Quick Check:

   Async streams need async keyword and await inside [OK]

Hint: Async streams require async keyword and await inside loops [OK]

Common Mistakes:

• Omitting await inside async streams
• Returning Task<IAsyncEnumerable> instead of IAsyncEnumerable
• Not marking method async when using yield return asynchronously