Eu tenho um BLoC que consome uma entrada brutaStream (que gera uma lista de objetos JSON) e a transforma em objetos utilizáveis usando umStreamTransformer. A interface do usuário mostra essa lista. O usuário pode aplicar um filtro (ele próprio um fluxo no BLoC), de modo que o BLoC atualize o transformador de fluxo de entrada com os respectivoswhere(...) afirmações.

A pergunta é: quando o filtro é alterado, a interface do usuário não é atualizada porque o fluxo de saída depende dos eventos do fluxo de entrada JSON, não do fluxo do filtro. Minha suposição é que eu preciso criar meu próprio fluxo no qual encaminhar eventos de entrada e eventos de filtro ou repetir no fluxo de entrada transformado o último evento, para que o transformador tenha a chance de buscá-lo. Como isso é feito corretamente? Um exemplo ajudaria muito!