rx/core/observablebase.py
def group_join(self, right, left_duration_mapper, right_duration_mapper,
                   result_mapper) -> 'ObservableBase':
        """Correlates the elements of two sequences based on overlapping
        durations, and groups the results.

        Keyword arguments:
        right -- The right observable sequence to join elements for.
        left_duration_mapper -- A function to select the duration (expressed
            as an observable sequence) of each element of the left observable
            sequence, used to determine overlap.
        right_duration_mapper -- A function to select the duration (expressed
            as an observable sequence) of each element of the right observable
            sequence, used to determine overlap.
        result_mapper -- A function invoked to compute a result element for
            any element of the left sequence with overlapping elements from the
            right observable sequence. The first parameter passed to the
            function is an element of the left sequence. The second parameter
            passed to the function is an observable sequence with elements from
            the right sequence that overlap with the left sequence's element.

        Returns an observable sequence that contains result elements computed
        from source elements that have an overlapping duration.
        """
        from ..operators.observable.groupjoin import group_join
        return group_join(self, right, left_duration_mapper, right_duration_mapper,
                          result_mapper)
Correlates the elements of two sequences based on overlapping
        durations, and groups the results.

        Keyword arguments:
        right -- The right observable sequence to join elements for.
        left_duration_mapper -- A function to select the duration (expressed
            as an observable sequence) of each element of the left observable
            sequence, used to determine overlap.
        right_duration_mapper -- A function to select the duration (expressed
            as an observable sequence) of each element of the right observable
            sequence, used to determine overlap.
        result_mapper -- A function invoked to compute a result element for
            any element of the left sequence with overlapping elements from the
            right observable sequence. The first parameter passed to the
            function is an element of the left sequence. The second parameter
            passed to the function is an observable sequence with elements from
            the right sequence that overlap with the left sequence's element.

        Returns an observable sequence that contains result elements computed
        from source elements that have an overlapping duration.
        
Correlates the elements of two sequences based on overlapping
durations, and groups the results.

Keyword arguments:
right -- The right observable sequence to join elements for.
left_duration_mapper -- A function to select the duration (expressed
as an observable sequence) of each element of the left observable
sequence, used to determine overlap.
right_duration_mapper -- A function to select the duration (expressed
as an observable sequence) of each element of the right observable
sequence, used to determine overlap.
result_mapper -- A function invoked to compute a result element for
any element of the left sequence with overlapping elements from the
right observable sequence. The first parameter passed to the
function is an element of the left sequence. The second parameter
passed to the function is an observable sequence with elements from
the right sequence that overlap with the left sequence's element.

Returns an observable sequence that contains result elements computed
from source elements that have an overlapping duration.
Correlates the elements of two sequences based on overlapping durations and groups the results . Keyword arguments : right -- The right observable sequence to join elements for . left_duration_mapper -- A function to select the duration ( expressed as an observable sequence ) of each element of the left observable sequence used to determine overlap . right_duration_mapper -- A function to select the duration ( expressed as an observable sequence ) of each element of the right observable sequence used to determine overlap . result_mapper -- A function invoked to compute a result element for any element of the left sequence with overlapping elements from the right observable sequence . The first parameter passed to the function is an element of the left sequence . The second parameter passed to the function is an observable sequence with elements from the right sequence that overlap with the left sequence ' s element . Returns an observable sequence that contains result elements computed from source elements that have an overlapping duration .
def group_join(self, right, left_duration_mapper, right_duration_mapper,
                   result_mapper) -> 'ObservableBase':
        from ..operators.observable.groupjoin import group_join
        return group_join(self, right, left_duration_mapper, right_duration_mapper,
                          result_mapper)
def group_join ( self , right , left_duration_mapper , right_duration_mapper , result_mapper ) -> 'ObservableBase' : from . . operators . observable . groupjoin import group_join return group_join ( self , right , left_duration_mapper , right_duration_mapper , result_mapper )
Correlates the elements of two sequences based on overlapping
durations, and groups the results.
Correlates the elements of two sequences based on overlapping durations and groups the results .
"""Correlates the elements of two sequences based on overlapping
        durations, and groups the results.

        Keyword arguments:
        right -- The right observable sequence to join elements for.
        left_duration_mapper -- A function to select the duration (expressed
            as an observable sequence) of each element of the left observable
            sequence, used to determine overlap.
        right_duration_mapper -- A function to select the duration (expressed
            as an observable sequence) of each element of the right observable
            sequence, used to determine overlap.
        result_mapper -- A function invoked to compute a result element for
            any element of the left sequence with overlapping elements from the
            right observable sequence. The first parameter passed to the
            function is an element of the left sequence. The second parameter
            passed to the function is an observable sequence with elements from
            the right sequence that overlap with the left sequence's element.

        Returns an observable sequence that contains result elements computed
        from source elements that have an overlapping duration.
        """
self
right
left_duration_mapper
right_duration_mapper
result_mapper