rx/core/observablebase.py
def group_by_until(self, key_mapper, element_mapper, duration_mapper) -> 'ObservableBase':
        """Groups the elements of an observable sequence according to a
        specified key mapper function. A duration mapper function is used
        to control the lifetime of groups. When a group expires, it receives
        an OnCompleted notification. When a new element with the same key value
        as a reclaimed group occurs, the group will be reborn with a new
        lifetime request.

        1 - observable.group_by_until(
                lambda x: x.id,
                None,
                lambda : Rx.Observable.never()
            )
        2 - observable.group_by_until(
                lambda x: x.id,
                lambda x: x.name,
                lambda: Rx.Observable.never()
            )
        3 - observable.group_by_until(
                lambda x: x.id,
                lambda x: x.name,
                lambda:  Rx.Observable.never(),
                lambda x: str(x))

        Keyword arguments:
        key_mapper -- A function to extract the key for each element.
        duration_mapper -- A function to signal the expiration of a group.

        Returns a sequence of observable groups, each of which corresponds to
        a unique key value, containing all elements that share that same key
        value. If a group's lifetime expires, a new group with the same key
        value can be created once an element with such a key value is
        encountered.
        """
        from ..operators.observable.groupbyuntil import group_by_until
        return group_by_until(self, key_mapper, element_mapper, duration_mapper)
Groups the elements of an observable sequence according to a
        specified key mapper function. A duration mapper function is used
        to control the lifetime of groups. When a group expires, it receives
        an OnCompleted notification. When a new element with the same key value
        as a reclaimed group occurs, the group will be reborn with a new
        lifetime request.

        1 - observable.group_by_until(
                lambda x: x.id,
                None,
                lambda : Rx.Observable.never()
            )
        2 - observable.group_by_until(
                lambda x: x.id,
                lambda x: x.name,
                lambda: Rx.Observable.never()
            )
        3 - observable.group_by_until(
                lambda x: x.id,
                lambda x: x.name,
                lambda:  Rx.Observable.never(),
                lambda x: str(x))

        Keyword arguments:
        key_mapper -- A function to extract the key for each element.
        duration_mapper -- A function to signal the expiration of a group.

        Returns a sequence of observable groups, each of which corresponds to
        a unique key value, containing all elements that share that same key
        value. If a group's lifetime expires, a new group with the same key
        value can be created once an element with such a key value is
        encountered.
        
Groups the elements of an observable sequence according to a
specified key mapper function. A duration mapper function is used
to control the lifetime of groups. When a group expires, it receives
an OnCompleted notification. When a new element with the same key value
as a reclaimed group occurs, the group will be reborn with a new
lifetime request.



Keyword arguments:
key_mapper -- A function to extract the key for each element.
duration_mapper -- A function to signal the expiration of a group.

Returns a sequence of observable groups, each of which corresponds to
a unique key value, containing all elements that share that same key
value. If a group's lifetime expires, a new group with the same key
value can be created once an element with such a key value is
encountered.
Groups the elements of an observable sequence according to a specified key mapper function . A duration mapper function is used to control the lifetime of groups . When a group expires it receives an OnCompleted notification . When a new element with the same key value as a reclaimed group occurs the group will be reborn with a new lifetime request . Keyword arguments : key_mapper -- A function to extract the key for each element . duration_mapper -- A function to signal the expiration of a group . Returns a sequence of observable groups each of which corresponds to a unique key value containing all elements that share that same key value . If a group ' s lifetime expires a new group with the same key value can be created once an element with such a key value is encountered .
def group_by_until(self, key_mapper, element_mapper, duration_mapper) -> 'ObservableBase':
        from ..operators.observable.groupbyuntil import group_by_until
        return group_by_until(self, key_mapper, element_mapper, duration_mapper)
def group_by_until ( self , key_mapper , element_mapper , duration_mapper ) -> 'ObservableBase' : from . . operators . observable . groupbyuntil import group_by_until return group_by_until ( self , key_mapper , element_mapper , duration_mapper )
Groups the elements of an observable sequence according to a
specified key mapper function.
Groups the elements of an observable sequence according to a specified key mapper function .
"""Groups the elements of an observable sequence according to a
        specified key mapper function. A duration mapper function is used
        to control the lifetime of groups. When a group expires, it receives
        an OnCompleted notification. When a new element with the same key value
        as a reclaimed group occurs, the group will be reborn with a new
        lifetime request.

        1 - observable.group_by_until(
                lambda x: x.id,
                None,
                lambda : Rx.Observable.never()
            )
        2 - observable.group_by_until(
                lambda x: x.id,
                lambda x: x.name,
                lambda: Rx.Observable.never()
            )
        3 - observable.group_by_until(
                lambda x: x.id,
                lambda x: x.name,
                lambda:  Rx.Observable.never(),
                lambda x: str(x))

        Keyword arguments:
        key_mapper -- A function to extract the key for each element.
        duration_mapper -- A function to signal the expiration of a group.

        Returns a sequence of observable groups, each of which corresponds to
        a unique key value, containing all elements that share that same key
        value. If a group's lifetime expires, a new group with the same key
        value can be created once an element with such a key value is
        encountered.
        """
self
key_mapper
element_mapper
duration_mapper