combine2<A, S> method

StreamSubscription<S> combine2<A, S>({
  1. required Rx<A> a,
  2. required S combiner(
    1. T t,
    2. A a
    ),
  3. required Rx<S> to,
})

Implementation

Async.StreamSubscription<S> combine2<A, S>({
  required Rx<A> a,
  required S Function(T t, A a) combiner,
  required Rx<S> to,
}) =>
    Reactive.CombineLatestStream.combine2(
      subject.stream.asBroadcastStream(),
      a.stream.asBroadcastStream(),
      (t, a) => combiner(t as T, a as A),
    ).listen(to);