Function emit

task/buy.py:208–223

(
        kind: str,
        message: str | None,
        update: BuyStreamUpdate | None = None,
    )

    state = BuyStreamState()

    def emit(
        kind: str,
        message: str | None,
        update: BuyStreamUpdate | None = None,
    ):
        if update is not None:
            update.apply_to(state)
        if message is not None:
            state.last_message = message

        return BuyStreamEvent(
            kind=kind,
            message=message,
            state=copy.deepcopy(state),
            data=update.to_dict() if update is not None else {},
        )

    def handle_proxy_failure(
        reason: str,