Skip to content

consume_responses

fastagency.ui.mesop.message.consume_responses #

consume_responses(
    responses: Iterable[MesopMessage],
) -> Iterator[None]
Source code in fastagency/ui/mesop/message.py 
53
54
55
56
57
58
59
60
61
def consume_responses(responses: Iterable[MesopMessage]) -> Iterator[None]:
    for message in responses:
        state = me.state(State)
        handle_message(state, message)
        yield
        if not isinstance(message.io_message, KeepAlive):
            me.scroll_into_view(key="end_of_messages")
        yield
    yield