Module accumulator 

Stateful streaming accumulator for thinking-tag detection.

An LLM may stream < in one SSE chunk, thi in the next, and nk> in a third. ThinkingAccumulator handles this by buffering partial tags and only emitting classified ThinkingEvents once enough bytes have arrived to decide.

Structs

ThinkingAccumulator

Stateful accumulator for streaming thinking-tag detection.

Enums

AccState 🔒

Internal state of the accumulator FSM.

Constants

CLOSE_TAG 🔒

The canonical closing tag (lowercase for matching).

OPEN_TAG_PREFIX 🔒

All possible opening-tag prefixes after normalisation (lowercase). Used to determine whether the buffer could still become a valid tag.

Functions

is_potential_open_tag_prefix 🔒

Check whether s is a valid prefix of any opening tag we recognise.

safe_thinking_emit_len 🔒

Return how many bytes from the start of buf are safe to emit as thinking content — i.e. bytes that cannot be part of a </think> tag.