rx/operators/observable/partition.py
def partition(source: ObservableBase, predicate: Predicate = None,
              predicate_indexed: PredicateIndexed = None) -> List[ObservableBase]:
    """Returns two observables which partition the observations of the
    source by the given function. The first will trigger observations for
    those values for which the predicate returns true. The second will
    trigger observations for those values where the predicate returns false.
    The predicate is executed once for each subscribed observer. Both also
    propagate all error observations arising from the source and each
    completes when the source completes.

    Keyword arguments:
    predicate -- The function to determine which output Observable will
        trigger a particular observation.

    Returns a list of observables. The first triggers when the predicate
    returns True, and the second triggers when the predicate returns False.
    """

    published = source.publish().ref_count()
    return [
        published.filter(predicate=predicate, predicate_indexed=predicate_indexed),
        published.filter(predicate_indexed=lambda x, i: not (predicate(x) if predicate else predicate_indexed(x, i)))
    ]
Returns two observables which partition the observations of the
    source by the given function. The first will trigger observations for
    those values for which the predicate returns true. The second will
    trigger observations for those values where the predicate returns false.
    The predicate is executed once for each subscribed observer. Both also
    propagate all error observations arising from the source and each
    completes when the source completes.

    Keyword arguments:
    predicate -- The function to determine which output Observable will
        trigger a particular observation.

    Returns a list of observables. The first triggers when the predicate
    returns True, and the second triggers when the predicate returns False.
    
Returns two observables which partition the observations of the
source by the given function. The first will trigger observations for
those values for which the predicate returns true. The second will
trigger observations for those values where the predicate returns false.
The predicate is executed once for each subscribed observer. Both also
propagate all error observations arising from the source and each
completes when the source completes.

Keyword arguments:
predicate -- The function to determine which output Observable will
trigger a particular observation.

Returns a list of observables. The first triggers when the predicate
returns True, and the second triggers when the predicate returns False.
Returns two observables which partition the observations of the source by the given function . The first will trigger observations for those values for which the predicate returns true . The second will trigger observations for those values where the predicate returns false . The predicate is executed once for each subscribed observer . Both also propagate all error observations arising from the source and each completes when the source completes . Keyword arguments : predicate -- The function to determine which output Observable will trigger a particular observation . Returns a list of observables . The first triggers when the predicate returns True and the second triggers when the predicate returns False .
def partition(source: ObservableBase, predicate: Predicate = None,
              predicate_indexed: PredicateIndexed = None) -> List[ObservableBase]:
    published = source.publish().ref_count()
    return [
        published.filter(predicate=predicate, predicate_indexed=predicate_indexed),
        published.filter(predicate_indexed=lambda x, i: not (predicate(x) if predicate else predicate_indexed(x, i)))
    ]
def partition ( source : ObservableBase , predicate : Predicate = None , predicate_indexed : PredicateIndexed = None ) -> List [ ObservableBase ] : published = source . publish ( ) . ref_count ( ) return [ published . filter ( predicate = predicate , predicate_indexed = predicate_indexed ) , published . filter ( predicate_indexed = lambda x , i : not ( predicate ( x ) if predicate else predicate_indexed ( x , i ) ) ) ]
Returns two observables which partition the observations of the
source by the given function.
Returns two observables which partition the observations of the source by the given function .
"""Returns two observables which partition the observations of the
    source by the given function. The first will trigger observations for
    those values for which the predicate returns true. The second will
    trigger observations for those values where the predicate returns false.
    The predicate is executed once for each subscribed observer. Both also
    propagate all error observations arising from the source and each
    completes when the source completes.

    Keyword arguments:
    predicate -- The function to determine which output Observable will
        trigger a particular observation.

    Returns a list of observables. The first triggers when the predicate
    returns True, and the second triggers when the predicate returns False.
    """
source
ObservableBase
predicate
Predicate
predicate_indexed
PredicateIndexed