สร้างสตรีมด้วย async*
ส่งเหตุการณ์จากตัวสร้าง
สร้างสตรีมด้วย async* เป็นบทเรียน Dart Academy ฟรีบน CoddyKit นี่คือบทเรียนที่ 4 จากทั้งหมด 4 บทเรียน คุณสามารถอ่านบทเรียนทั้งหมดด้านล่างฟรี — จากนั้นลองปฏิบัติด้วยตัวคุณเองในเบราว์เซอร์พร้อมตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7 บทเรียนนี้เป็นส่วนหนึ่งของเส้นทางการเรียน Dart Academy และความก้าวหน้าของคุณจะซิงค์ข้ามเว็บและแอป CoddyKit คอร์ส Dart Academy มีบทเรียนทั้งหมด 4 บทเรียน
สร้างสตรีมของคุณเอง
จนถึงตอนนี้คุณได้ใช้สตรีมที่ผู้อื่นสร้างไว้แล้ว ต่อไปคุณจะสร้างสตรีมด้วยตัวเองโดยใช้ ตัวสร้างแบบ async ซึ่งเป็นวิธีที่สะอาดและชัดเจนที่สุดในการส่งเหตุการณ์
คีย์เวิร์ด async*
ระบุฟังก์ชันด้วย async* แล้วฟังก์ชันนั้นจะกลายเป็นตัวสร้างสตรีม ชนิดค่าที่คืนกลับมาคือ Stream และสามารถส่งค่าออกมาได้ตลอดเวลา 🚿
Stream<int> countTo(int n) async* {
// body uses yield
}yield ส่งค่าออกมา
ภายในฟังก์ชัน async* yield จะส่งค่าหนึ่งค่าเข้าสู่สตรีม การทำงานจะหยุดพักตรงนั้นจนกว่าผู้รับฟังจะพร้อมรับค่าถัดไป
Stream<int> oneTwo() async* {
yield 1;
yield 2;
}yield ภายในลูป
ใช้ yield ร่วมกับลูปเพื่อส่งค่าจำนวนมากออกมา แต่ละรอบจะส่งตัวเลขถัดไปเข้าสู่สตรีมโดยอัตโนมัติ
Stream<int> countTo(int n) async* {
for (var i = 1; i <= n; i++) yield i;
}await ภายใน async*
เนื่องจากฟังก์ชันเป็น async คุณจึงสามารถใช้ await ระหว่าง yield ได้ ทำให้คุณดึงข้อมูลหรือหน่วงเวลาก่อนส่งเหตุการณ์ถัดไป
Stream<int> ticker() async* {
while (true) {
await Future.delayed(Duration(seconds: 1));
yield DateTime.now().second;
}
}yield* ส่งต่อสตรีม
ใช้ yield* เพื่อส่งทุกเหตุการณ์จากสตรีมอื่นภายในตัวสร้างของคุณ วิธีนี้จะแทรกสตรีมทั้งหมดนั้นเข้าไปในสตรีมของคุณ
Stream<int> combined() async* {
yield* countTo(3);
yield 99;
}จะเริ่มทำงานเมื่อมีผู้รับฟัง
ฟังก์ชัน async* จะยังไม่เริ่มทำงานจนกว่าจะมีผู้รับฟัง เนื้อหาภายในฟังก์ชันจะทำงานเมื่อผู้รับฟังดึงค่าแต่ละค่าออกมาเท่านั้น ⏸️
การหยุดพักเคารพผู้รับฟัง
หากผู้รับฟังหยุดพัก ตัวสร้างก็จะหยุดพักที่ yield ถัดไปด้วย กลไกควบคุมแรงดันย้อนกลับนี้ช่วยไม่ให้ผู้ผลิตส่งข้อมูลมากเกินกว่าที่ผู้รับจะจัดการได้
ข้อผิดพลาดจาก async*
การใช้ throw ภายในฟังก์ชัน async* จะกลายเป็นเหตุการณ์ข้อผิดพลาดบนสตรีม ผู้รับฟังสามารถดักจับข้อผิดพลาดนี้ได้เช่นเดียวกับข้อผิดพลาดจากสตรีมอื่น
Stream<int> risky() async* {
yield 1;
throw 'boom';
}ใช้ตัวสร้างของคุณ
อ่านสตรีมที่สร้างขึ้นด้วยวิธีปกติโดยใช้ await for ค่าที่ yield ออกมาแต่ละค่าจะไหลเข้าสู่ลูปตามลำดับ
await for (final n in countTo(3)) {
print(n);
}async* เทียบกับ StreamController
สำหรับเอาต์พุตที่ดึงตามลำดับ async* จะเรียบง่ายกว่า StreamController ให้เลือกใช้ตัวควบคุมก็ต่อเมื่อเหตุการณ์มาจากคอลแบ็กภายนอก
ตรวจสอบความเข้าใจ
คุณจะส่งค่าออกมาจากฟังก์ชัน async* ได้อย่างไร
ทบทวน
คุณสร้างสตรีมด้วย async* โดยส่งค่าผ่าน yield ส่งต่อด้วย yield* และรอระหว่างเหตุการณ์ต่าง ๆ ตอนนี้คุณสามารถใช้และสร้างสตรีมได้แล้ว 🎉
เรียนรู้ Dart ด้วย AI tutor — ฟรี
เขียนและเรียกใช้โค้ดจริงในเบราว์เซอร์ของคุณ รับความช่วยเหลือทันทีจาก AI tutor 24/7 และเรียนรู้ต่อจากที่คุณหยุดบนเว็บหรือในแอป
- คอร์ส
- 30
- บทเรียน
- 120
คำถามที่พบบ่อย
บทเรียน “สร้างสตรีมด้วย async*” ฟรีหรือไม่
ใช่ — ข้อความเต็มของ “สร้างสตรีมด้วย async*” ฟรีให้อ่านที่นี่บนเว็บ เพื่อปฏิบัติแบบโต้ตอบ (ตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7) และปลดล็อคส่วนที่เหลือของคอร์ส Dart Academy ให้อัปเกรดเป็น CoddyKit PRO คอร์ส Dart Academy มีบทเรียนทั้งหมด 4 บทเรียน
คุณจะเรียนรู้อะไรในบทเรียน “สร้างสตรีมด้วย async*”
ส่งเหตุการณ์จากตัวสร้าง คุณปฏิบัติ Dart Academy ด้วยโค้ดที่ใช้งานได้จริงที่คุณเรียกใช้โดยตรงในเบราว์เซอร์ และติวเตอร์ AI ตลอด 24/7 ตอบคำถามของคุณขณะที่คุณไปผ่านบทเรียน
คุณต้องมีประสบการณ์ก่อนที่จะเริ่มเรียน Dart Academy หรือไม่
ไม่จำเป็นต้องมีประสบการณ์มาก่อน Dart Academy บน CoddyKit ออกแบบมาสำหรับผู้เริ่มต้นไปจนถึงผู้เรียนขั้นสูง คุณสามารถเริ่มต้นที่นี่หรือเริ่มจากตัวแรกและเรียนด้วยความเร็วของคุณเอง นี่คือบทเรียนที่ 4 จากทั้งหมด 4 บทเรียน
บทเรียน “สร้างสตรีมด้วย async*” ใช้เวลานานแค่ไหน
บทเรียน CoddyKit ส่วนใหญ่ใช้เวลาประมาณ 5–10 นาที แต่ละบทเรียนจึงสั้นและเป็นแบบโต้ตอบ คุณสามารถก้าวหน้าอย่างต่อเนื่องและกลับมาเรียนต่อจากตรงที่เพิ่งหยุดบนเว็บและแอปได้เลย
ฉันเขียนและรันโค้ดในบทเรียน Dart Academy นี้ได้ไหม
ได้ บทเรียน Dart Academy ทุกบทมีตัวแก้ไขโค้ดในตัว คุณจึงเขียนและรันโค้ดจริงได้เลยในเบราว์เซอร์ และได้รับข้อเสนอแนะจาก AI ในทันที — ไม่ต้องติดตั้งในเครื่องของคุณ
บทเรียนทั้งหมดในหลักสูตรนี้
- รับฟังด้วย await for
- สตรีมแบบเดี่ยวกับแบบกระจายเสียง
- แปลงสตรีม: map, where และ take
- สร้างสตรีมด้วย async*