Это либо ошибка, либо я неправильно понимаю часть 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