✏️ Editing: _maxby.py Read Only

from typing import Callable, List, Optional, TypeVar

from reactivex import Observable, typing
from reactivex.internal.basic import default_sub_comparer

from ._minby import extrema_by

_T = TypeVar("_T")
_TKey = TypeVar("_TKey")

def max_by_(
    key_mapper: typing.Mapper[_T, _TKey],
    comparer: Optional[typing.SubComparer[_TKey]] = None,
) -> Callable[[Observable[_T]], Observable[List[_T]]]:

cmp = comparer or default_sub_comparer

def max_by(source: Observable[_T]) -> Observable[List[_T]]:
        """Partially applied max_by operator.

Returns the elements in an observable sequence with the maximum
        key value.

Examples:
            >>> res = max_by(source)

Args:
            source: The source observable sequence to.

Returns:
            An observable sequence containing a list of zero or more
            elements that have a maximum key value.
        """
        return extrema_by(source, key_mapper, cmp)

return max_by

__all__ = ["max_by_"]

🔐 Sid Gifari File Manager Pro