Skip to content

You're not viewing the latest version. Click here to go to latest.

FastStream

ConnectionState

Initializing search

ag2ai/faststream

Features
Tutorial
Kafka
RabbitMQ
NATS
Redis
Reference - Code API
FastStream People
Contributing
Release Notes

FastStream

ag2ai/faststream

Features
Tutorial
Kafka
RabbitMQ
NATS
Redis
Reference - Code API
Reference - Code API
- Reference - Code API
- Public API
- All API
  All API
  - faststream
    faststream
    
    AckPolicy
    
    AsyncAPI
    
    BaseMiddleware
    
    BatchPublishCommand
    
    Context
    
    Depends
    
    ExceptionMiddleware
    
    FastStream
    
    Header
    
    Path
    
    PublishCommand
    
    PublishType
    
    Response
    
    SourceType
    
    StreamMessage
    
    TestApp
    
    apply_types
    
    app
    
    asgi
    
    confluent
    
    exceptions
    
    kafka
    
    message
    
    middlewares
    
    nats
    nats
    
    AckPolicy
    
    ConsumerConfig
    
    DeliverPolicy
    
    DiscardPolicy
    
    ExternalStream
    
    JStream
    
    KvWatch
    
    NatsBroker
    
    NatsPublishCommand
    
    NatsPublisher
    
    NatsResponse
    
    NatsRoute
    
    NatsRouter
    
    ObjWatch
    
    Placement
    
    PubAck
    
    PullSub
    
    RePublish
    
    ReplayPolicy
    
    RetentionPolicy
    
    StorageType
    
    StreamConfig
    
    StreamSource
    
    TestApp
    
    TestNatsBroker
    
    broker
    
    configs
    
    fastapi
    
    helpers
    helpers
    
    KVBucketDeclarer
    
    OSBucketDeclarer
    
    StreamBuilder
    
    bucket_declarer
    
    obj_storage_declarer
    
    state
    state
    
    ConnectedState
    
    ConnectionState ConnectionState
    Table of contents
    
    ConnectionState
    
    connection
    
    EmptyConnectionState
    
    stream_builder
    
    message
    
    opentelemetry
    
    parser
    
    prometheus
    
    publisher
    
    response
    
    schemas
    
    security
    
    subscriber
    
    testing
    
    opentelemetry
    
    params
    
    prometheus
    
    rabbit
    
    redis
    
    response
    
    security
    
    specification
    
    types
FastStream People
Contributing
Release Notes

Table of contents

ConnectionState
- connection

ConnectionState

faststream.nats.helpers.state.ConnectionState #

Bases: Protocol[ClientT]

connection `instance-attribute` #

connection

EmptyConnectionState

© 2025 AG2AI Inc.

Made with Material for MkDocs