Я не совсем уверен, как я использую набор текста в RxPy. В настоящее время я делаю это, и это вполне работает:
b: rx.typing.Subject[int, int] = Subject()
b.pipe(
ops.map(lambda a: a + 1)
)
b.on_next(1)
IDE (PyCharm) предупреждает меня, если on_next
получает входные данные, которые имеют неправильный тип значения. Но моя IDE ошибочно говорит, что у моего предмета нет метода pipe
. Кажется, что IDE не знает, что субъект также является наблюдаемым. Должен ли я явно объявить, что Субъект представляет собой смешение нескольких типов?