`Stream.listen` în Dart

Stream: șiruri de evenimente asincrone Dart 2.0

Începe ascultarea unui stream: o funcție pentru fiecare valoare, una pentru erori, una pentru final.

Sintaxă

StreamSubscription<T> listen(void onData(T event)?, {Function? onError, void onDone()?, bool? cancelOnError})

Ce face `Stream.listen`

listen este modul de bază de a primi evenimentele unui stream; await for și metodele ca toList îl folosesc în spate. Primești un StreamSubscription, prin care poți pune pauză sau anula ascultarea.

onData se cheamă pentru fiecare valoare, onError pentru fiecare eroare, iar onDone o dată, la închiderea stream-ului. Cu cancelOnError: true, prima eroare oprește ascultarea. Spre deosebire de await for, listen nu blochează funcția: codul de după el rulează imediat.

Parametri

Parametru	Descriere
`onData`	Funcția chemată cu fiecare valoare.
`onError`	Opțional: funcția chemată cu fiecare eroare (eroarea și, opțional, stiva).
`onDone`	Opțional: funcția chemată când stream-ul se închide.
`cancelOnError`	Opțional: dacă e `true`, ascultarea se oprește la prima eroare.

Ce returnează

Un StreamSubscription<T>.

Exemple

Exemplul 1: Date, erori și final

import 'dart:async';

Stream<String> mesaje() async* {
  yield 'Bună!';
  yield 'Ce faci?';
  throw const FormatException('mesaj corupt');
}

Future<void> main() async {
  final gata = Completer<void>();
  mesaje().listen(
    (m) => print('mesaj: $m'),
    onError: (Object e) => print('eroare: $e'),
    onDone: () {
      print('conversație încheiată');
      gata.complete();
    },
  );
  print('listen nu blochează: rulez imediat');
  await gata.future;
}

Rezultat

listen nu blochează: rulez imediat
mesaj: Bună!
mesaj: Ce faci?
eroare: FormatException: mesaj corupt
conversație încheiată

Exemplul 2: cancelOnError oprește la prima eroare

Future<void> main() async {
  final s = Stream<int>.multi((c) {
    c.add(1);
    c.addError(StateError('senzor deconectat'));
    c.add(2);
    c.close();
  });
  final abonament = s.listen(
    (v) => print('valoare $v'),
    onError: (Object e) => print('eroare: $e'),
    cancelOnError: true,
  );
  await Future.delayed(const Duration(milliseconds: 20));
  print('valoarea 2 nu a mai ajuns');
  await abonament.cancel();
}