Struct OpenStreamWriterOptions 

pub struct OpenStreamWriterOptions {
    pub progress_token: String,
    pub publish_frame: PublishFrame,
    pub content_type: Option<String>,
    pub on_close: Option<OnCloseHook>,
    pub on_abort: Option<OnAbortHook>,
    pub idle_timeout: Option<Duration>,
    pub probe_timeout: Duration,
}

Construction options for an OpenStreamWriter.

Fields

progress_token: String

The stream id (stringified progressToken).

publish_frame: PublishFrame

Outbound publisher (same seam as the session).

content_type: Option<String>

Optional advisory start content type (writer-settable, receiver-ignored).

on_close: Option<OnCloseHook>

Fired after a terminal close frame is published.

on_abort: Option<OnAbortHook>

Fired after a terminal abort frame is published.

idle_timeout: Option<Duration>

Sender-side keepalive idle window (CEP-41 §Timeout and Keepalive). None disables keepalive (e.g. unit tests). When set, the writer arms the window once it starts streaming and probes the peer with ping if no inbound frame arrives within this duration; a missing pong aborts with "Probe timeout", closing a leak where a silently-disconnected client left the writer (and its upstream producer) alive indefinitely.

probe_timeout: Duration

Time the writer waits for a matching pong after probing before aborting. Ignored when idle_timeout is None.

Implementations

impl OpenStreamWriterOptions

pub fn with_keepalive(self, idle: Duration, probe: Duration) -> Self

Enable sender-side keepalive with the given idle/probe windows.