יסודות ה-Streams

חלק מהיחידה תכנות מונחה עצמים במסלול ה-Dart של Coddy. שיעור 77 מתוך 110.

בעוד ש-Future מספק ערך יחיד, Stream מספק רצף של ערכים לאורך זמן. חשבו עליו כעל צינור שיכול לפלוט כמה פריטי נתונים — מושלם לאירועים, לעדכונים בזמן אמת או לעיבוד נתונים חלק אחר חלק.

אפשר ליצור זרם פשוט באמצעות Stream.fromIterable() או פונקציית מחולל אסינכרונית עם async* ו-yield:

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

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

מילת המפתח async* מסמנת פונקציה שמחזירה זרם, ו-yield פולט כל ערך. כדי לצרוך את הזרם, השתמשו ב-await for, שמעבד כל ערך כשהוא מגיע.

אפשר גם להאזין לזרם באמצעות המתודה listen(), שמקבלת פונקציית callback:

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

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

ההבדל העיקרי מ-Futures: Future מסתיים פעם אחת עם ערך יחיד, בעוד ש-Stream יכול להפיק ערכים רבים לפני שהוא מסתיים. לכן Streams מתאימים במיוחד לטיפול בנתונים מתמשכים, כמו אינטראקציות של משתמשים, קריאות חיישנים או נתונים שמגיעים במקטעים.

אתגר

קל

בואו נבנה מערכת לספירה לאחור שפולטת ערכים לאורך זמן באמצעות זרמים! תיצרו מחלקה שמייצרת רצף של מספרים בספירה לאחור, ותדגימו כיצד זרמים מספקים ערכים מרובים במקום ערך אחד בלבד.

תארגנו את הקוד בשני קבצים:

countdown.dart: צרו מחלקה Countdown שמייצרת זרמי ספירה לאחור. המחלקה צריכה לכלול:
- שדה start (int) ששומר את מספר ההתחלה של הספירה לאחור
- בנאי שמקבל את מספר ההתחלה
- מתודה countDown() שמחזירה Stream<int>. השתמשו ב־async* וב־yield כדי לפלוט מספרים מ־start ועד 0 (כולל)
- מתודה countDownWithMessage() שמחזירה Stream<String>. היא צריכה לפלוט מחרוזות בפורמט 'T-minus [number]' עבור כל מספר מ־start ועד 1, ואז לפלוט את 'Liftoff!' כערך האחרון
main.dart: ייבאו את קובץ הספירה לאחור והדגימו את שתי מתודות הזרם. הפונקציה הראשית צריכה להיות async ולבצע את הפעולות הבאות:
- צרו מופע של Countdown שמתחיל מ־3
- הדפיסו את Number countdown:
- השתמשו ב־await for כדי לעבור על countDown() ולהדפיס כל מספר
- הדפיסו שורה ריקה
- הדפיסו את Launch sequence:
- השתמשו ב־await for כדי לעבור על countDownWithMessage() ולהדפיס כל הודעה

שימו לב כיצד כל פקודת yield פולטת ערך דרך הזרם, ו־await for מעבדת כל ערך כשהוא מגיע. בניגוד ל־Future שמספק תוצאה אחת, הזרמים שלכם יפלטו ערכים מרובים ברצף!

פלט צפוי:

Number countdown:
3
2
1
0

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

נסו בעצמכם

import 'countdown.dart';

Future<void> main() async {
  // TODO: צרו מופע של Countdown שמתחיל ב-3
  
  // TODO: הדפיסו 'Number countdown:'
  
  // TODO: השתמשו ב-await for כדי לעבור על countDown() ולהדפיס כל מספר
  
  // TODO: הדפיסו שורה ריקה
  
  // TODO: הדפיסו 'Launch sequence:'
  
  // TODO: השתמשו ב-await for כדי לעבור על countDownWithMessage() ולהדפיס כל הודעה
}