Lesson 48 of 59

5 mins read

Streams: Asynchronous Data Flows & StreamControllers

In Plain English

While a `Future` delivers a single asynchronous value, a `Stream<T>` delivers a continuous sequence of asynchronous events over time (like user click events, WebSocket messages, GPS coordinates, or chat messages). Streams can be consumed using `.listen()` or `await for` loops, and produced programmatically via **`StreamController`**.

The Mental Model

"A Future is a delivery package delivered once to your doorstep; a Stream is a flowing kitchen faucet that pours a continuous stream of water droplets over time until you turn off the handle."

Deep Dive: How It Works

Single-Subscription vs Broadcast Streams: Single-subscription streams allow only ONE listener; Broadcast streams (`Stream.broadcast()`) allow multiple concurrent subscribers.

`await for` Loop: Pauses and consumes stream events sequentially as they arrive.

`StreamController<T>`: A manager object with a `sink` (to add events/errors) and a `stream` (to listen to events).

Syntax Blueprint

// Creating a StreamController
final controller = StreamController<String>();
controller.stream.listen((msg) => print("Received: $msg"));
controller.sink.add("Event 1");
controller.close();

Producing events via Sink and consuming via Stream subscription.

Core Rules to Remember

Continuous Async Events: Ideal for WebSockets, user interaction events, and reactive state management.

StreamSubscription Management: Cancel subscriptions (`sub.cancel()`) to prevent memory leaks in Flutter.

StreamController & Sinks: Use Sinks to emit events and errors into custom streams.

Common Beginner Traps & How to Fix Them

Mistake:Adding multiple `.listen()` listeners to a single-subscription stream.

Why it happens: Single-subscription streams throw `StateError: Stream has already been listened to`.

How to fix: Convert the stream using `.asBroadcastStream()` if multiple listeners are needed.

Pro Tip: In Flutter, use the `StreamBuilder` widget to automatically rebuild UI components whenever a Stream emits new data.

Live Interactive Example

Hit Run Code to see it live

Emitting and Consuming Events with StreamController

Python 3.12

Output Console

Click "Run Code" to view the rendered output.

How it works: The StreamController emitted 3 integers through its sink and notified the stream subscriber.

Your Turn: Micro Challenge

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

Micro Exercise

Listen to Periodic Stream

Create a stream `final stream = Stream.fromIterable(["A", "B", "C"]);`.
Use `await for (final item in stream) { print("Item: $item"); }`.

Sandbox Output

Click "Run & Check" to test your solution.

Finished reading and practicing?

Mark this lesson as completed to update your course progress.