Как используются стримы во Flutter?

Стримы во Flutter используются для обработки последовательности асинхронных событий. Это могут быть данные из сети, пользовательский ввод, изменения состояния и т.д.

Ключевые аспекты использования:

• Asynchronous programming: Стримы основаны на Future, но представляют собой поток событий, а не одно будущее значение.
• UI updates: Стримы часто используются для обновления пользовательского интерфейса в ответ на изменения данных без блокировки главного потока.
• Reactive programming: Они являются основой для реактивных подходов в управлении состоянием (например, с использованием BLoC или Provider с StreamProvider).

Основные классы:

• Stream: Представляет последовательность асинхронных событий. Нельзя напрямую создать Stream, он создается источником данных (например, HttpClient, File.watch, StreamController).
• StreamController: Позволяет создавать и управлять стримами. Используется для добавления данных или ошибок в стрим.
• StreamSubscription: Объект, который возвращается при подписке на стрим. Позволяет слушать события и отменять подписку.

  // Создание стрима через StreamController
  final _controller = StreamController<int>();

  // Добавление данных в стрим
  void addData(int data) {
    _controller.sink.add(data);
  }

  // Получение стрима для прослушивания
  Stream<int> get stream => _controller.stream;

  // Закрытие контроллера, когда он больше не нужен
  void dispose() {
    _controller.close();
  }

Примеры использования:

• Обработка событий нажатия кнопок: StreamController<void> _buttonClicked = StreamController();
• Получение данных из WebSocket: _socket.listen((data) => _streamController.add(data));
• Реализация таймеров: Stream<int> countStream = Stream.periodic(Duration(seconds: 1), (count) => count);

Интеграция с виджетами:

• StreamBuilder: Виджет, который перестраивает свою подветку всякий раз, когда стрим эмитирует новое значение.

  StreamBuilder<int>(
    stream: countStream, // Тот самый стрим из примера выше
    builder: (BuildContext context, AsyncSnapshot<int> snapshot) {
      if (snapshot.hasError) {
        return Text('Error: ${snapshot.error}');
      }
      switch (snapshot.connectionState) {
        case ConnectionState.none:
          return Text('Select a number');
        case ConnectionState.waiting:
          return Text('Waiting...');
        case ConnectionState.active:
          return Text('${snapshot.data}'); // Отображение текущего значения стрима
        case ConnectionState.done:
          return Text('${snapshot.data} (Closed)');
      }
    },
  )

Преимущества:

• Упрощают асинхронную обработку данных.
• Позволяют создавать отзывчивые пользовательские интерфейсы.
• Являются ключевым элементом архитектурных паттернов, таких как BLoC.

Важно управлять жизненным циклом подписок (StreamSubscription.cancel()) и контроллеров (StreamController.close()) для предотвращения утечек памяти.