Lesson 49 of 59

5 mins read

Stream Transformers & Asynchronous Generators (async*)

In Plain English

When you need to generate a stream of asynchronous values on demand, Dart provides **Asynchronous Generators** (`async*`). Inside an `async*` function, you can use `await` to pause for asynchronous operations and `yield` to emit values into the resulting `Stream<T>`. Streams also support functional transformation methods like `.map()`, `.where()`, `.take()`, and `.transform()`.

The Mental Model

"An `async*` generator is like a podcast broadcaster: the host records and edits each episode over a period of time (`await`), and as soon as an episode is rendered, it is published to the subscriber feed (`yield`)."

Deep Dive: How It Works

`async*` Modifier: Declares an asynchronous generator returning `Stream<T>`.

`yield`: Emits a value into the stream without terminating the generator function.

`yield*`: Delegates emission to another existing `Stream` (`yield* secondaryStream;`).

Stream Transformations: `.where((e) => e.isValid).map((e) => transform(e))` builds reactive event pipelines.

Syntax Blueprint

Stream<int> countStream(int max) async* {
  for (int i = 1; i <= max; i++) {
    await Future.delayed(Duration(milliseconds: 10));
    yield i; // Emits into stream
  }
}

Asynchronous generator function yielding stream values with non-blocking delays.

Core Rules to Remember

Asynchronous Sequence Emission: Combine `await` and `yield` to produce streams lazily.

Stream Operator Chaining: Filter and map streams just like standard synchronous iterables.

Delegated yield*: Stream forwarding with `yield*` flattens nested streams seamlessly.

Common Beginner Traps & How to Fix Them

Mistake:Confusing `sync*` (returns `Iterable`) with `async*` (returns `Stream`).

Why it happens: Similar syntax.

How to fix: Use `sync*` for synchronous on-demand collections; use `async*` when operations require `await`.

Pro Tip: Use `async*` to create periodic heartbeat tickers and live database query watchers.

Live Interactive Example

Hit Run Code to see it live

Building an Asynchronous Stream Generator

Python 3.12

Output Console

Click "Run Code" to view the rendered output.

How it works: The async* generator yielded 3 timed string ticks and completed the stream.

Your Turn: Micro Challenge

No pressure! Edit the starter code below and test your solution with instant feedback.

Micro Exercise

Create Async Stream Generator

Define `Stream<int> generateMultiples(int base, int count) async* { for (var i = 1; i <= count; i++) { yield base * i; } }`.
In `main() async`, consume `generateMultiples(5, 3)` using `await for` and print each value.

Sandbox Output

Click "Run & Check" to test your solution.

Finished reading and practicing?

Mark this lesson as completed to update your course progress.