combineLatest2<A, B, C> function

Stream<C> combineLatest2<A, B, C>(
  1. Stream<A> a,
  2. Stream<B> b,
  3. C mapper(
    1. A,
    2. B
    )
)

Implementation

Stream<C> combineLatest2<A, B, C>(
  Stream<A> a,
  Stream<B> b,
  C Function(A, B) mapper,
) =>
    ZipStream(
      [a, b],
      (values) => mapper(
        values[0] as A,
        values[1] as B,
      ),
    ).asBroadcastStream();