TestGame/addons/reactivex/operators/_combinelatest.gd

22 lines
684 B
GDScript3
Raw Permalink Normal View History

2024-12-27 21:00:07 +01:00
static func combine_latest_(others_) -> Callable:
var others : Array[Observable] = GDRx.util.unpack_arg(others_)
var combine_latest = func(source : Observable) -> Observable:
# """Merges the specified observable sequences into one
# observable sequence by creating a tuple whenever any
# of the observable sequences produces an element.
#
# Examples:
# >>> var obs = combine_latest.call(source)
#
# Returns:
# An observable sequence containing the result of combining
# elements of the sources into a tuple.
# """
var sources : Array[Observable] = others.duplicate()
sources.push_front(source)
return GDRx.obs.combine_latest(sources)
return combine_latest