Skip to content

Compile nats wildcard

faststream.nats.schemas.js_stream.compile_nats_wildcard #

compile_nats_wildcard(
    pattern: str,
) -> tuple[Optional[Pattern[str]], str]

Compile logs.{user}.> to regex and logs.*.> subject.

Source code in faststream/nats/schemas/js_stream.py 
225
226
227
228
def compile_nats_wildcard(pattern: str) -> tuple[Optional["Pattern[str]"], str]:
    """Compile `logs.{user}.>` to regex and `logs.*.>` subject."""
    address = Address(pattern, NATS_ADDRESS_SYNTAX)
    return address.regex, address.broker_address