`combine` & `CombineSpec`

Un solo combinador para «quién dispara» y «quién debe haber hablado» — más zipAll y withLatestFromAll.

FxEvents<List<T>> combine<T>(Iterable<CombineSpec<T>> specs) class CombineSpec<T>(Stream<T> source, {bool causesEmit = true, bool requireFirst = true}) FxEvents<R> FxEvents<Stream<T>>.zipAll<R>([R Function(List<T> values)? project]) FxEvents<R> FxEvents<T>.withLatestFromAll<R>(Iterable<Stream<Object?>> others, R Function(T value, List<Object?> latest) combine)

Lección

combineLatest, withLatestFrom y zip difieren en quién puede disparar una emisión y en si todo lado debe haber hablado. combine es la forma unificada: una lista de CombineSpec, cada uno un source más dos flags. Es una función de nivel superior, no FxEvents.combine — Dart no puede añadir estáticos a FxEvents desde otro archivo.

causesEmit: true (el valor por defecto) significa que un evento de esta fuente puede producir una salida, una vez que todo spec requireFirst tiene un valor. Specs todos-true son FxEvents.combineLatestAll. causesEmit: false significa que esta fuente es solo contexto: actualiza el slot pero nunca dispara una emisión por sí sola — eso es withLatestFrom. requireFirst: true (el valor por defecto) retiene toda emisión hasta que esta fuente ha producido al menos un valor; false deja que el slot sea null hasta que hable. El resultado se cierra cuando todas las fuentes se han cerrado.

Junto a él viven dos combinadores más. zipAll sobre FxEvents<Stream<T>> recoge cada stream interior hasta que el exterior completa, y luego los empareja por índice — los interiores ni siquiera se suscriben hasta entonces. withLatestFromAll es el withLatestFrom N-ario: en cada evento de la fuente, lo combina con el más reciente de todos los demás, descartando los eventos de la fuente que llegan antes de que todos los demás hayan hablado. Capa de eventos de fxdart, según el combineLatest / withLatestFrom / zipAll de Rx.

Demo 1 · Ambos lados disparan

Demo 2 · Solo contexto — causesEmit: false

Pruébalo tú

Ejercicio: zipAll sobre un stream de streams, y withLatestFromAll sobre una fuente.

import 'dart:async';

import 'package:fxdart/fxdart.dart';

/// Emits each (offsetMs, value) pair at its offset, closing at [closeMs].
Stream<T> timed<T>(List<(int, T)> events, int closeMs) {
  final c = StreamController<T>();
  for (final (ms, v) in events) {
    Timer(Duration(milliseconds: ms), () => c.add(v));
  }
  Timer(Duration(milliseconds: closeMs), c.close);
  return c.stream;
}

Future<void> main() async {
  // zipAll waits for the OUTER to complete, then zips collected inners
  // by index. Write zipAll<List<int>>() when omitting project.
  final zipped = await fxEvents(Stream.fromIterable([
    Stream.fromIterable([1, 2]),
    Stream.fromIterable([10, 20]),
  ])).zipAll<List<int>>().toList();
  print(zipped); // [[1, 10], [2, 20]]

// withLatestFromAll is N-ary withLatestFrom: only SOURCE events emit,
  // stamped with every other's latest. Early source events are dropped
  // until every other has spoken.
  final stamped = await fxEvents(timed([(0, 'r1'), (80, 'r2'), (160, 'r3')], 220))
      .withLatestFromAll(
        [timed([(40, 'v1'), (120, 'v2')], 220)],
        (v, latest) => '$v@${latest.first}',
      )
      .toList();
  print(stamped); // [r2@v1, r3@v2]
}

Relacionado: combineLatest — ambos lados disparan, el CombineSpec todos-true · withLatestFrom — unilateral, el spec causesEmit: false · waitAll — zip, combineLatestAll, concat

combine & CombineSpec

Lección

Demo 1 · Ambos lados disparan

Demo 2 · Solo contexto — causesEmit: false

Pruébalo tú

`combine` & `CombineSpec`