использование count в flat_map, по-видимому, неожиданно возвращает 0 - PullRequest
0 голосов
/ 12 февраля 2020

Это либо ошибка, либо я неправильно понимаю часть rxpy.

from rx import operators as ops

items = ["Alpha", "Beta", "Gamma", "Delta", "Epsilon"]

rx.from_list(items).pipe(
    ops.group_by(lambda x: len(x)),
    ops.flat_map(lambda g: g.pipe(
        ops.count(),
        ops.map(lambda c: (g.key, c)),
    )),
    ops.to_dict(lambda kv: kv[0], lambda kv: kv[1])
).subscribe(print)

возвращает: {5: 0, 4: 0, 7: 0}

, а я ожидаю {5: 3, 4: 1, 7: 1}

версия: rx==3.0.1

...