dart:io

Метод listen

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

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

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

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

Обратный вызов onError должен быть типа void onError(error) или void onError(error, StackTrace stackTrace). Если onError принимает два аргумента, он вызывается с объектом ошибки и стеком вызовов (который может быть null, если сам поток получил ошибку без стека вызовов). В противном случае он вызывается только с объектом ошибки. Если onError опущено, любые ошибки в потоке считаются необработанными и будут переданы текущему обработчику ошибок Zone. По умолчанию необработанные асинхронные ошибки обрабатываются так, как будто они были необработанными ошибками верхнего уровня.

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

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

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

Источник

StreamSubscription<List<int>> listen(void onData(List<int> event),
    {Function onError, void onDone(), bool cancelOnError}) {
  return _stream.listen(onData,
      onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}