combine3<A, B, S> method

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

Implementation

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