Tengo un BLoC que consume una entrada sin procesarStream (que produce una lista de objetos JSON) y la transforma en objetos utilizables usando unaStreamTransformer. La interfaz de usuario muestra esa lista. El usuario puede aplicar un filtro (en sí mismo, un flujo en el BLoC), de modo que el BLoC actualice el transformador de flujo de entrada con lawhere(...) declaraciones.

La pregunta es: cuando el filtro cambia, la interfaz de usuario no se actualiza porque la secuencia de salida depende de los eventos de la secuencia de entrada JSON, no de la secuencia del filtro. Mi suposición es que necesito crear mi propio flujo en el que reenvío eventos de entrada y eventos de filtro, o necesito repetir en el flujo de entrada transformado el último evento, de modo que el transformador tenga la oportunidad de recogerlo. ¿Cómo se hace esto correctamente? ¡Un ejemplo ayudaría mucho!