Отлично, большое спасибо! Бонусные баллы за ссылки на реактивные документы.

я есть BLoC, который потребляет необработанный вводStream (который выдает список объектов JSON) и преобразует его в пригодные для использования объекты, используяStreamTransformer, Пользовательский интерфейс показывает этот список. Пользователь может применить фильтр (сам поток в BLoC), так что BLoC обновляет преобразователь входного потока с соответствующимиwhere(...) заявления.

Вопрос заключается в следующем: при изменении фильтра пользовательский интерфейс не обновляется, поскольку выходной поток зависит от событий входного потока JSON, а не от потока фильтра. Мое предположение заключается в том, что мне нужно либо создать свой собственный поток, в который я пересылаю как входные события, так и события фильтрации, или мне нужно повторить в преобразованном входном потоке последнее событие, чтобы у преобразователя была возможность его забрать. Как это сделано правильно? Пример очень поможет!

Ответы на вопрос(1)

Ваш ответ на вопрос