`Stream.multi` în Dart

Stream: șiruri de evenimente asincrone Dart 2.9

Creează un stream care poate fi ascultat de mai multe ori; fiecare ascultător primește propriul controller.

Sintaxă

factory Stream<T>.multi(void onListen(MultiStreamController<T> controller), {bool isBroadcast = false})

Ce face `Stream.multi`

La fiecare ascultare, Stream.multi cheamă funcția onListen cu un MultiStreamController nou. Prin el trimiți valori (add), erori (addError) și închizi stream-ul (close) doar pentru acel ascultător.

Astfel fiecare ascultător primește toate evenimentele de la început, spre deosebire de un stream broadcast. Este un mod simplu de a crea un stream cu evenimente exacte (valori și erori), util în teste.

Parametri

Parametru	Descriere
`onListen`	Funcția chemată pentru fiecare ascultător nou, cu controller-ul lui.
`isBroadcast`	Opțional: dacă stream-ul se raportează ca broadcast.

Ce returnează

Un Stream<T> care poate fi ascultat de mai multe ori.

Exemple

Exemplul 1: Fiecare ascultător primește totul

Future<void> main() async {
  var ascultari = 0;
  final meniu = Stream<String>.multi((c) {
    ascultari++;
    c.add('ciorbă');
    c.add('sarmale');
    c.close();
  });
  print(await meniu.toList());
  print(await meniu.toList());
  print('Ascultări: $ascultari');
}

Rezultat

[ciorbă, sarmale]
[ciorbă, sarmale]
Ascultări: 2

Exemplul 2: Valori și erori pentru un test

import 'dart:async';

Future<void> main() async {
  final citiri = Stream<int>.multi((c) {
    c.add(10);
    c.addError(const FormatException('citire invalidă'));
    c.add(12);
    c.close();
  });
  final gata = Completer<void>();
  citiri.listen(
    (v) => print('valoare $v'),
    onError: (Object e) => print('eroare: $e'),
    onDone: gata.complete,
  );
  await gata.future;
  print('gata');
}