Stream Denetleyicileri

Coddy'nin Dart Journey'sinin Nesne Yönelimli Programlama bölümünün bir parçası. Ders 78 / 110.

async* oluşturucular, önceden tanımlanmış verilerle akışlar (streams) oluşturmak için harika olsa da, bazen kodunuzun farklı bölümlerinden bir akışa veri eklemek gibi daha fazla kontrole ihtiyaç duyarsınız. İşte burada StreamController devreye girer.

Bir StreamController, bir akış için yönetici görevi görür. Veri eklemek için bir "sink" ve dinleyicilerin abone olabileceği bir "stream" sağlar:

import 'dart:async';

void main() {
  var controller = StreamController<String>();
  
  // Akışı dinle
  controller.stream.listen((data) {
    print('Received: $data');
  });
  
  // Veriyi sink aracılığıyla ekle
  controller.add('Hello');
  controller.add('World');
  
  controller.close();  // İşlem bittiğinde her zaman kapatın
}

add() yöntemi akışa yeni değerler iter ve tüm dinleyiciler bunları anında alır. Kaynakları serbest bırakmak için işiniz bittiğinde her zaman close() yöntemini çağırmalısınız.

Varsayılan olarak bir akışın yalnızca bir dinleyicisi olabilir. Birden fazla dinleyici için bir yayın denetleyicisi kullanın:

import 'dart:async';

void main() {
  var controller = StreamController<int>.broadcast();
  
  controller.stream.listen((n) => print('Listener 1: $n'));
  controller.stream.listen((n) => print('Listener 2: $n'));
  
  controller.add(42);
  controller.close();
}

StreamControllers, veri değiştiğinde uygulamanızın birden fazla bölümünü bilgilendirmek, kullanıcı eylemlerini işlemek veya nesneleriniz içindeki gerçek zamanlı güncellemeleri yönetmek gibi olay tabanlı sınıflar oluşturmak için OOP'de temel öneme sahiptir.

Görev

Kolay

Birden fazla abonenin mesajları gerçek zamanlı olarak almasını sağlayan bir mesaj merkezi sistemi oluşturalım! Mesaj akışını yönetmek için bir StreamController kullanacak ve yayın akışlarının birden fazla dinleyiciyi nasıl etkinleştirdiğini göstereceksin.

Kodunu iki dosyada düzenleyeceksin:

message_hub.dart: Bir StreamController kullanarak mesaj dağıtımını yöneten bir MessageHub sınıfı oluştur. Merkezin şunları yapmalı:
- Birden fazla dinleyicinin abone olabilmesi için dahili olarak bir yayın StreamController<String> kullan
- Dinleyicilerin abone olabilmesi için akışı döndüren messages adlı bir getter sağla
- Akışa bir mesaj ekleyen bir broadcast(String message) yöntemine sahip ol
- Denetleyiciyi kapatan bir shutdown() yöntemine sahip ol
main.dart: Mesaj merkezini içe aktar ve aynı akışı dinleyen birden fazla abonenin bulunduğu bir senaryo oluştur:
- Bir MessageHub örneği oluştur
- Mesajları şu formatta yazdıran ilk dinleyiciyi ekle: Subscriber A: [message]
- Mesajları şu formatta yazdıran ikinci dinleyiciyi ekle: Subscriber B: [message]
- Üç mesaj yayınla: Hello everyone, Welcome to the hub ve Goodbye
- Merkezi kapat

dart:async öğesine erişmek için mesaj merkezi dosyana StreamController içe aktarmasını eklemeyi unutma. Her iki abonenin de yayınlanan her mesajı aldığını fark et — yayın akışlarının gücü budur!

Beklenen çıktı:

Subscriber A: Hello everyone
Subscriber B: Hello everyone
Subscriber A: Welcome to the hub
Subscriber B: Welcome to the hub
Subscriber A: Goodbye
Subscriber B: Goodbye

Kendin dene

import 'message_hub.dart';

void main() {
  // TODO: Bir MessageHub örneği oluşturun
  
  // TODO: Şunu yazdıran ilk dinleyiciyi ekleyin: Subscriber A: [message]
  
  // TODO: Şunu yazdıran ikinci dinleyiciyi ekleyin: Subscriber B: [message]
  
  // TODO: Üç mesaj yayınlayın:
  // - "Hello everyone"
  // - "Welcome to the hub"
  // - "Goodbye"
  
  // TODO: Hub'ı kapatın
}