Struct EventStreamTimeoutConfig 

#[non_exhaustive]
pub struct EventStreamTimeoutConfig {
    pub initial_message: Option<Duration>,
    pub message_completion: Option<Duration>,
    pub idle: Option<Duration>,
}

Independent event-stream read deadlines. None disables a deadline.

The first RPC frame is read before invoking the handler, including when it is an ordinary event from a stream-only input. Only initial_message bounds this read. If it is disabled, neither message_completion nor idle provides a fallback, so the first RPC frame has no event-stream read deadline.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

initial_message: Option<Duration>

Bounds the entire first RPC frame, including waiting for its first bytes. Does not apply to REST streams.

message_completion: Option<Duration>

Bounds reading a frame from its first bytes until completion. Applies to every REST frame and to RPC frames after the first.

idle: Option<Duration>

Bounds waiting for a frame’s first bytes. Applies before the first REST frame and between frames, after the first RPC frame completes.

Implementations

impl EventStreamTimeoutConfig

pub fn with_initial_message(self, timeout: Option<Duration>) -> Self

pub fn with_message_completion(self, timeout: Option<Duration>) -> Self

pub fn with_idle(self, timeout: Option<Duration>) -> Self

Trait Implementations

impl Clone for EventStreamTimeoutConfig

fn clone(&self) -> EventStreamTimeoutConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventStreamTimeoutConfig

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

Formats the value using the given formatter.

impl Default for EventStreamTimeoutConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for EventStreamTimeoutConfig

fn eq(&self, other: &EventStreamTimeoutConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for EventStreamTimeoutConfig

impl Eq for EventStreamTimeoutConfig

impl StructuralPartialEq for EventStreamTimeoutConfig