rx/core/observablebase.py
def concat_all(self) -> 'ObservableBase':
        """Concatenates an observable sequence of observable sequences.

        Returns:
            An observable sequence that contains the elements of each
            observed inner sequence, in sequential order.
        """
        return self.merge(max_concurrent=1)
Concatenates an observable sequence of observable sequences.

        Returns:
            An observable sequence that contains the elements of each
            observed inner sequence, in sequential order.
        
Concatenates an observable sequence of observable sequences.
Concatenates an observable sequence of observable sequences .
def concat_all(self) -> 'ObservableBase':
        return self.merge(max_concurrent=1)
def concat_all ( self ) -> 'ObservableBase' : return self . merge ( max_concurrent = 1 )
Concatenates an observable sequence of observable sequences.
Concatenates an observable sequence of observable sequences .
"""Concatenates an observable sequence of observable sequences.

        Returns:
            An observable sequence that contains the elements of each
            observed inner sequence, in sequential order.
        """
An observable sequence that contains the elements of each
observed inner sequence, in sequential order.
An observable sequence that contains the elements of each observed inner sequence in sequential order .
self