Stream-Grundlagen

Teil des Abschnitts Objektorientierte Programmierung der Dart-Journey von Coddy. Lektion 77 von 110.

Während ein Future einen einzelnen Wert liefert, liefert ein Stream eine Sequenz von Werten über die Zeit. Stellen Sie es sich wie eine Leitung vor, die mehrere Datenstücke ausgeben kann – perfekt für Ereignisse, Echtzeit-Updates oder die schrittweise Verarbeitung von Daten.

Du kannst einen einfachen Stream mit Stream.fromIterable() oder einer asynchronen Generatorfunktion mit async* und yield erstellen:

Stream<int> countToThree() async* {
  yield 1;
  yield 2;
  yield 3;
}

Future<void> main() async {
  await for (var number in countToThree()) {
    print(number);
  }
}
// Ausgabe: 1, 2, 3

Das Schlüsselwort async* kennzeichnet eine Funktion, die einen Stream zurückgibt, und yield gibt jeden Wert aus. Um den Stream zu konsumieren, verwende await for, das jeden Wert verarbeitet, sobald er eintrifft.

Du kannst einen Stream auch mit der Methode listen() anhören, die eine Callback-Funktion übernimmt:

Stream<String> greetings() async* {
  yield 'Hello';
  yield 'Hi';
  yield 'Hey';
}

void main() {
  greetings().listen((message) {
    print(message);
  });
}

Der wichtigste Unterschied zu Futures: Ein Future wird einmal mit einem einzelnen Wert abgeschlossen, während ein Stream viele Werte ausgeben kann, bevor er beendet ist. Dadurch eignen sich Streams ideal für die Verarbeitung fortlaufender Daten wie Benutzerinteraktionen, Sensormesswerte oder Daten, die in Teilen eintreffen.

Aufgabe

Einfach

Erstellen wir ein Countdown-Timersystem, das mithilfe von Streams im Laufe der Zeit Werte ausgibt! Du erstellst eine Klasse, die eine Folge von Countdown-Zahlen erzeugt, und zeigst dabei, wie Streams mehrere Werte statt nur eines einzigen liefern.

Du organisierst deinen Code in zwei Dateien:

countdown.dart: Erstelle eine Countdown-Klasse, die Countdown-Streams erzeugt. Deine Klasse sollte Folgendes enthalten:
- Ein start-Feld (int), das die Startzahl für den Countdown speichert
- Einen Konstruktor, der die Startzahl entgegennimmt
- Eine Methode countDown(), die einen Stream<int> zurückgibt. Verwende async* und yield, um Zahlen von start bis einschließlich 0 auszugeben
- Eine Methode countDownWithMessage(), die einen Stream<String> zurückgibt. Sie sollte für jede Zahl von 'T-minus [number]' bis start Zeichenketten im Format 1 ausgeben und anschließend als letzten Wert 'Liftoff!' ausgeben
main.dart: Importiere deine Countdown-Datei und demonstriere beide Stream-Methoden. Deine main-Funktion sollte asynchron sein und:
- Eine Countdown-Instanz erstellen, die bei 3 startet
- Number countdown: ausgeben
- await for verwenden, um durch countDown() zu iterieren und jede Zahl auszugeben
- Eine leere Zeile ausgeben
- Launch sequence: ausgeben
- await for verwenden, um durch countDownWithMessage() zu iterieren und jede Nachricht auszugeben

Beachte, wie jede yield-Anweisung einen Wert über den Stream ausgibt und await for jeden Wert verarbeitet, sobald er eintrifft. Anders als ein Future, das ein einziges Ergebnis liefert, geben deine Streams mehrere Werte nacheinander aus!

Erwartete Ausgabe:

Number countdown:
3
2
1
0

Launch sequence:
T-minus 3
T-minus 2
T-minus 1
Liftoff!

Probier es selbst

import 'countdown.dart';

Future<void> main() async {
  // TODO: Erstelle eine Countdown-Instanz, die bei 3 beginnt
  
  // TODO: Gib 'Number countdown:' aus
  
  // TODO: Verwende await for, um countDown() zu durchlaufen und jede Zahl auszugeben
  
  // TODO: Gib eine Leerzeile aus
  
  // TODO: Gib 'Launch sequence:' aus
  
  // TODO: Verwende await for, um countDownWithMessage() zu durchlaufen und jede Nachricht auszugeben
}