1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
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_"]
|
