Skip to content

PullSub

faststream.nats.pull_sub.PullSub #

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

Bases: BaseModel

Source code in faststream/nats/pull_sub.py 
10
11
12
13
14
15
16
17
18
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: 1 year ago2023-11-13