Class StreamingState

src/mcp_cli/display/models.py:137–325

Complete state of an active streaming operation. This replaces scattered state variables with a single, type-safe model.

class StreamingState(BaseModel):
    """Complete state of an active streaming operation.

    This replaces scattered state variables with a single, type-safe model.
    """

    # Content accumulation
    accumulated_content: str = Field(
        default="", description="All content received so far"
    )
    reasoning_content: str = Field(
        default="", description="Reasoning/thinking content accumulated"
    )

    # Chunk tracking
    chunks_received: int = Field(default=0, description="Total chunks processed")
    last_chunk_time: float = Field(
        default_factory=time.time, description="Timestamp of last chunk"
    )

    # Content detection
    detected_type: ContentType = Field(
        default=ContentType.UNKNOWN, description="Detected content type"
    )

    # Phase tracking
    phase: StreamingPhase = Field(
        default=StreamingPhase.INITIALIZING, description="Current streaming phase"
    )

    # Timing
    start_time: float = Field(
        default_factory=time.time, description="When streaming started"
    )
    end_time: float | None = Field(default=None, description="When streaming completed")

    # Completion
    finish_reason: str | None = Field(default=None, description="Why streaming ended")
    interrupted: bool = Field(default=False, description="Whether user interrupted")

    # Buffer caps
    max_accumulated_chars: int = Field(
        default=1_048_576,
        description="Max accumulated content chars (0=unlimited)",
    )
    max_chunks: int = Field(
        default=50_000,
        description="Max chunks before stall detection (0=unlimited)",
    )
    content_capped: bool = Field(
        default=False, description="Whether content hit the buffer cap"
    )

    model_config = {"frozen": False}

    @property
    def elapsed_time(self) -> float:
        """Calculate elapsed time since streaming started."""