Skip to content

PullSub

faststream.nats.pull_sub.PullSub #

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

Bases: BaseModel

Source code in faststream/nats/pull_sub.py 
11
12
13
14
15
16
17
18
19
20
21
def __init__(
    self,
    batch_size: int = 1,
    timeout: Optional[float] = 5.0,
    batch: bool = False,
) -> None:
    super().__init__(
        batch_size=batch_size,
        timeout=timeout,
        batch=batch,
    )

batch class-attribute instance-attribute #

batch: bool = Field(default=False)

batch_size class-attribute instance-attribute #

batch_size: int = Field(default=1)

timeout class-attribute instance-attribute #

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