Struct SyntaxStreamState 

pub struct SyntaxStreamState { /* private fields */ }

Per-session token streaming state stored in ExtensionMap.

Manages subscriber channels for clients that want real-time token updates via the StreamTokens gRPC endpoint.

Separation from SyntaxSessionState

Core driver storage lives in reovim-driver-syntax (accessible to modules). This type handles server-only streaming infrastructure that depends on tokio and reovim-protocol (not available to modules).

Implementations

impl SyntaxStreamState

pub fn new() -> Self

Create a new empty stream state.

pub fn subscribe(&mut self) -> Receiver<TokenUpdate>

Subscribe to token updates.

Returns a receiver that will receive TokenUpdate messages when buffers are modified and re-tokenized.

Channel Size

The channel has a buffer of 16 messages. If a client falls behind, older updates may be dropped.

pub const fn subscriber_count(&self) -> usize

Get the number of active subscribers.

pub const fn has_subscribers(&self) -> bool

Check if there are no subscribers.

pub fn broadcast(&mut self, update: &TokenUpdate)

Broadcast a token update to all subscribers.

Removes disconnected subscribers automatically.

pub fn notify_edit( &mut self, syntax: &mut SyntaxSessionState, buffer_id: BufferId, content: &str, edit: &SyntaxEdit, start_line: u64, end_line: u64, )

Notify subscribers of a buffer edit.

This method:

1. Updates the syntax driver incrementally via driver.update()
2. Gets updated tokens for the affected region
3. Broadcasts TokenUpdate to all subscribers

Arguments

• syntax - The syntax session state containing drivers
• buffer_id - The buffer that was modified
• content - The full buffer content after the edit
• edit - The edit description for incremental parsing
• start_line - First line affected by the edit (for TokenUpdate)
• end_line - Last line affected by the edit (for TokenUpdate)

pub fn send_full_refresh( &mut self, syntax: &SyntaxSessionState, buffer_id: BufferId, total_lines: u64, )

Send a full token refresh for a buffer.

Call this when a new subscriber connects or when a buffer’s language changes.

Trait Implementations

impl Debug for SyntaxStreamState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SyntaxStreamState

fn default() -> SyntaxStreamState

Returns the “default value” for a type.

impl SessionExtension for SyntaxStreamState

fn create() -> Self

Create default state for a new session.

fn as_text_input_sink(&mut self) -> Option<&mut dyn TextInputSink>

Return self as a TextInputSink if this extension accepts text input.