Skip to content

NatsResponse

faststream.nats.response.NatsResponse #

NatsResponse(
    body: SendableMessage,
    *,
    headers: dict[str, str] | None = None,
    correlation_id: str | None = None,
    stream: str | None = None,
)

Bases: Response

Source code in faststream/nats/response.py 
13
14
15
16
17
18
19
20
21
22
23
24
25
26
def __init__(
    self,
    body: "SendableMessage",
    *,
    headers: dict[str, str] | None = None,
    correlation_id: str | None = None,
    stream: str | None = None,
) -> None:
    super().__init__(
        body=body,
        headers=headers,
        correlation_id=correlation_id,
    )
    self.stream = stream

stream instance-attribute #

stream = stream

body instance-attribute #

body = body

headers instance-attribute #

headers = headers or {}

correlation_id instance-attribute #

correlation_id = correlation_id

as_publish_command #

as_publish_command() -> NatsPublishCommand
Source code in faststream/nats/response.py 
28
29
30
31
32
33
34
35
36
37
38
@override
def as_publish_command(self) -> "NatsPublishCommand":
    return NatsPublishCommand(
        message=self.body,
        headers=self.headers,
        correlation_id=self.correlation_id,
        _publish_type=PublishType.PUBLISH,
        # Nats specific
        subject="",
        stream=self.stream,
    )