Реактивное программирование с Pythox RX: как создать конвейер по условию? - PullRequest
Новая
       10

Реактивное программирование с Pythox RX: как создать конвейер по условию?

0 голосов
/ 01 апреля 2020

У меня есть функция, которая проверяет имя файла из списка файлов и говорит, должен ли конвейер rx загрузить этот файл или нет 

def _analyse_file(fruit_name: str) -> bool:
   if fruit_name in ['Apple', 'Orange', 'Banana']:
      return True
   else:
      return False

Итак, у меня есть список файлов files и я пытаюсь создать канал вот так 

rx.from_list(files).pipe( rx.pipe(some_actions_on_file)).subsribe(...)

Мне нужно добавить что-то, что перед созданием канала я вызову вышеописанную функцию и отфильтрую, из какого файла должен быть создан канал. Как добавить проверку условия?

...