Async streams with IAsyncEnumerable in C Sharp (C#) - Time & Space Complexity

Time Complexity: Async streams with IAsyncEnumerable

O(n)

Understanding Time Complexity

When using async streams with IAsyncEnumerable, it's important to understand how the time to process items grows as the number of items increases.

We want to know how the total work changes as more data is streamed asynchronously.

Scenario Under Consideration

Analyze the time complexity of the following code snippet.

public async IAsyncEnumerable<int> GenerateNumbersAsync(int count)
{
    for (int i = 0; i < count; i++)
    {
        await Task.Delay(10); // Simulate async work
        yield return i;
    }
}

public async Task ProcessNumbersAsync(int count)
{
    await foreach (var number in GenerateNumbersAsync(count))
    {
        Console.WriteLine(number);
    }
}
    

This code asynchronously generates numbers one by one, simulating a delay, and processes each number as it arrives.

Identify Repeating Operations

Identify the loops, recursion, array traversals that repeat.

• Primary operation: The for loop inside GenerateNumbersAsync that runs count times.
• How many times: Exactly once per item, so count times.

How Execution Grows With Input

Each item causes one loop iteration with a small async delay and a yield. As the number of items grows, the total time grows proportionally.

Input Size (n)	Approx. Operations
10	10 async yields and delays
100	100 async yields and delays
1000	1000 async yields and delays

Pattern observation: The total work grows linearly as the number of items increases.

Final Time Complexity

Time Complexity: O(n)

This means the time to process all items grows directly in proportion to the number of items streamed.

Common Mistake

[X] Wrong: "Because the method is async, it runs instantly regardless of input size."

[OK] Correct: Async means the method can pause and resume, but it still processes each item one by one, so total time depends on how many items there are.

Interview Connect

Understanding async streams helps you explain how programs handle data that arrives over time, a useful skill when working with real-world data sources like files, networks, or user input.

Self-Check

"What if we removed the await Task.Delay(10) inside the loop? How would the time complexity change?"

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