Skip to content

PullSub

faststream.nats.PullSub #

PullSub(
    batch_size: int = 1, timeout: Optional[float] = 5.0
)

Bases: BaseModel

Source code in faststream/nats/pull_sub.py
def __init__(
    self,
    batch_size: int = 1,
    timeout: Optional[float] = 5.0,
) -> None:
    super().__init__(
        batch_size=batch_size,
        timeout=timeout,
    )

batch_size class-attribute instance-attribute #

batch_size: int = Field(default=1)

timeout class-attribute instance-attribute #

timeout: Optional[float] = Field(default=5.0)

Last update: 2023-11-13