dart:async

Метод listen

Добавляет подписку на этот поток.

Возвращает StreamSubscription, который обрабатывает события этого потока с помощью предоставленных обработчиков onData, onError и onDone. Обработчики можно изменить в подписке, но изначально им присваиваются предоставленные функции.

При каждом событии данных из этого потока вызывается обработчик onData подписчика. Если onData равно null, ничего не происходит.

При возникновении ошибок в этом потоке обработчик onError вызывается с объектом ошибки и, возможно, трассировкой стека.

Обратный вызов onError должен иметь тип void Function(Object error) или void Function(Object error, StackTrace). Тип функции определяет, вызывается ли onError с аргументом трассировки стека. Аргумент трассировки стека может иметь значение StackTrace.empty, если этот поток получил ошибку без трассировки стека.

В противном случае он вызывается только с объектом ошибки. Если onError не указан, любые ошибки в этом потоке считаются необработанными и передаются обработчику ошибок текущей Zone. По умолчанию необработанные асинхронные ошибки рассматриваются как неперехваченные ошибки верхнего уровня.

Если этот поток закрывается и отправляет событие завершения, вызывается обработчик onDone. Если onDone равно null, ничего не происходит.

Если cancelOnError равно true, подписка автоматически отменяется при доставке первого события ошибки. Значение по умолчанию — false.

Пока подписка приостановлена или отменена, она не получает события, и ни одна из функций-обработчиков событий не вызывается.

Реализация

StreamSubscription<T> listen(void onData(T value)?,
    {Function? onError, void onDone()?, bool? cancelOnError}) {
  return _stream.listen(onData,
      onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}