rx/core/observablebase.py
def combine_latest(self, observables: Union['ObservableBase', Iterable['ObservableBase']],
                       mapper: Callable[[Any], Any]) -> 'ObservableBase':
        """Merges the specified observable sequences into one observable
        sequence by using the mapper function whenever any of the
        observable sequences produces an element. This can be in the
        form of an argument list of observables or an array.

        Examples:
            >>> obs = observable.combine_latest(obs1, obs2, obs3, lambda o1, o2, o3: o1 + o2 + o3)
            >>> obs = observable.combine_latest([obs1, obs2, obs3], lambda o1, o2, o3: o1 + o2 + o3)

        Returns:
            An observable sequence containing the result of combining
            elements of the sources using the specified result mapper
            function.
        """
        from ..operators.observable.combinelatest import combine_latest
        if isinstance(observables, typing.Observable):
            observables = [observables]

        args = [self] + list(observables)
        return combine_latest(args, mapper)
Merges the specified observable sequences into one observable
        sequence by using the mapper function whenever any of the
        observable sequences produces an element. This can be in the
        form of an argument list of observables or an array.

        Examples:
            >>> obs = observable.combine_latest(obs1, obs2, obs3, lambda o1, o2, o3: o1 + o2 + o3)
            >>> obs = observable.combine_latest([obs1, obs2, obs3], lambda o1, o2, o3: o1 + o2 + o3)

        Returns:
            An observable sequence containing the result of combining
            elements of the sources using the specified result mapper
            function.
        
Merges the specified observable sequences into one observable
sequence by using the mapper function whenever any of the
observable sequences produces an element. This can be in the
form of an argument list of observables or an array.
Merges the specified observable sequences into one observable sequence by using the mapper function whenever any of the observable sequences produces an element . This can be in the form of an argument list of observables or an array .
def combine_latest(self, observables: Union['ObservableBase', Iterable['ObservableBase']],
                       mapper: Callable[[Any], Any]) -> 'ObservableBase':
        from ..operators.observable.combinelatest import combine_latest
        if isinstance(observables, typing.Observable):
            observables = [observables]
        args = [self] + list(observables)
        return combine_latest(args, mapper)
def combine_latest ( self , observables : Union [ 'ObservableBase' , Iterable [ 'ObservableBase' ] ] , mapper : Callable [ [ Any ] , Any ] ) -> 'ObservableBase' : from . . operators . observable . combinelatest import combine_latest if isinstance ( observables , typing . Observable ) : observables = [ observables ] args = [ self ] + list ( observables ) return combine_latest ( args , mapper )
Merges the specified observable sequences into one observable
sequence by using the mapper function whenever any of the
observable sequences produces an element.
Merges the specified observable sequences into one observable sequence by using the mapper function whenever any of the observable sequences produces an element .
"""Merges the specified observable sequences into one observable
        sequence by using the mapper function whenever any of the
        observable sequences produces an element. This can be in the
        form of an argument list of observables or an array.

        Examples:
            >>> obs = observable.combine_latest(obs1, obs2, obs3, lambda o1, o2, o3: o1 + o2 + o3)
            >>> obs = observable.combine_latest([obs1, obs2, obs3], lambda o1, o2, o3: o1 + o2 + o3)

        Returns:
            An observable sequence containing the result of combining
            elements of the sources using the specified result mapper
            function.
        """
An observable sequence containing the result of combining
elements of the sources using the specified result mapper
function.
An observable sequence containing the result of combining elements of the sources using the specified result mapper function .
self
observables
Union['ObservableBase', Iterable['ObservableBase']]
mapper
Callable[[Any], Any]
examples
None