rx/core/observablebase.py
def merge(self, *args, max_concurrent=None):
        """Merges an observable sequence of observable sequences into an
        observable sequence, limiting the number of concurrent subscriptions
        to inner sequences. Or merges two observable sequences into a single
        observable sequence.

        1 - merged = sources.merge(max_concurrent=1)
        2 - merged = source.merge(other_source)

        Keyword arguments:
        max_concurrent -- [Optional] Maximum number of inner observable
            sequences being subscribed to concurrently or the second
            observable sequence.

        Returns the observable sequence that merges the elements of the
        inner sequences.
        """
        from ..operators.observable.merge import merge
        return merge(self, *args, max_concurrent=max_concurrent)
Merges an observable sequence of observable sequences into an
        observable sequence, limiting the number of concurrent subscriptions
        to inner sequences. Or merges two observable sequences into a single
        observable sequence.

        1 - merged = sources.merge(max_concurrent=1)
        2 - merged = source.merge(other_source)

        Keyword arguments:
        max_concurrent -- [Optional] Maximum number of inner observable
            sequences being subscribed to concurrently or the second
            observable sequence.

        Returns the observable sequence that merges the elements of the
        inner sequences.
        
Merges an observable sequence of observable sequences into an
observable sequence, limiting the number of concurrent subscriptions
to inner sequences. Or merges two observable sequences into a single
observable sequence.



Keyword arguments:
max_concurrent -- [Optional] Maximum number of inner observable
sequences being subscribed to concurrently or the second
observable sequence.

Returns the observable sequence that merges the elements of the
inner sequences.
Merges an observable sequence of observable sequences into an observable sequence limiting the number of concurrent subscriptions to inner sequences . Or merges two observable sequences into a single observable sequence . Keyword arguments : max_concurrent -- [ Optional ] Maximum number of inner observable sequences being subscribed to concurrently or the second observable sequence . Returns the observable sequence that merges the elements of the inner sequences .
def merge(self, *args, max_concurrent=None):
        from ..operators.observable.merge import merge
        return merge(self, *args, max_concurrent=max_concurrent)
def merge ( self , * args , max_concurrent = None ) : from . . operators . observable . merge import merge return merge ( self , * args , max_concurrent = max_concurrent )
Merges an observable sequence of observable sequences into an
observable sequence, limiting the number of concurrent subscriptions
to inner sequences.
Merges an observable sequence of observable sequences into an observable sequence limiting the number of concurrent subscriptions to inner sequences .
"""Merges an observable sequence of observable sequences into an
        observable sequence, limiting the number of concurrent subscriptions
        to inner sequences. Or merges two observable sequences into a single
        observable sequence.

        1 - merged = sources.merge(max_concurrent=1)
        2 - merged = source.merge(other_source)

        Keyword arguments:
        max_concurrent -- [Optional] Maximum number of inner observable
            sequences being subscribed to concurrently or the second
            observable sequence.

        Returns the observable sequence that merges the elements of the
        inner sequences.
        """
self
max_concurrent