expandFrom<R, O> method Null safety

HStream<Iterable<R>> expandFrom<R, O>(
  1. HStream<O> other,
  2. Iterable<R> expander(
    1. T? input,
    2. O? other
    )
)

Implementation

HStream<Iterable<R>> expandFrom<R, O>(HStream<O> other, Iterable<R> expander(T? input, O? other)) {
  return HStream<Iterable<R>>(
      expander(this.first, other.first),
      after.combineLatest(other.after, (ours, O theirs) {
        return expander(ours, theirs);
      }));
}