Skip to content

resolve_channel_messages

faststream.specification.asyncapi.v2_6_0.generate.resolve_channel_messages #

resolve_channel_messages(
    channel, channel_name, payloads, messages
)
Source code in faststream/specification/asyncapi/v2_6_0/generate.py 
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
def resolve_channel_messages(
    channel: Channel,
    channel_name: str,
    payloads: dict[str, dict[str, Any]],
    messages: dict[str, Message],
) -> None:
    if channel.subscribe is not None and channel.subscribe.message:
        assert isinstance(channel.subscribe.message, Message)

        channel.subscribe.message = _resolve_msg_payloads(
            channel.subscribe.message,
            channel_name,
            payloads,
            messages,
        )

    if channel.publish is not None:
        assert isinstance(channel.publish.message, Message)

        channel.publish.message = _resolve_msg_payloads(
            channel.publish.message,
            channel_name,
            payloads,
            messages,
        )