Struct StreamConfig 

pub struct StreamConfig {
    pub reliability: Reliability,
    pub window_bytes: u32,
    pub fairness_weight: u8,
    pub scheduled: bool,
    pub close_behavior: CloseBehavior,
}

Per-stream configuration supplied at open_stream time.

Configuration is immutable for the lifetime of a stream. Re-opening the same (peer, stream_id) with different config is a no-op with a warning log — the original config wins.

Fields

reliability: Reliability

Reliability mode. Defaults to FireAndForget.

window_bytes: u32

Initial credit window for the stream’s send path, in bytes. The sender starts with tx_credit_remaining = window_bytes and decrements on each socket send; receiver-driven StreamWindow grants replenish the counter. 0 disables backpressure (unbounded — v1 escape hatch). Defaults to DEFAULT_STREAM_WINDOW_BYTES.

fairness_weight: u8

Fair-scheduler quantum multiplier. 1 is equal-share; higher means this stream gets proportionally more packets per round.

scheduled: bool

Route this stream’s originating sends through the router’s FairScheduler rather than straight to the socket. Default false — every existing caller (nRPC streaming, control traffic) keeps the direct socket.send_to path. Set true for bulk transfers so their sends participate in per-stream weighted fairness and can’t monopolize the link against other scheduled streams. The scheduler’s queue depth becomes an additional backpressure source (surfaced as StreamError::Backpressure).

close_behavior: CloseBehavior

What to do with pending outbound packets on close.

Implementations

impl StreamConfig

pub fn new() -> Self

Start from defaults.

pub fn with_reliability(self, reliability: Reliability) -> Self

Set the reliability mode.

pub fn with_window_bytes(self, bytes: u32) -> Self

Set the per-stream window (queue depth cap).

pub fn with_fairness_weight(self, weight: u8) -> Self

Set the fair-scheduler weight (1 = equal share; higher = more).

pub fn with_scheduled(self, scheduled: bool) -> Self

Route this stream’s originating sends through the router’s fair scheduler (see Self::scheduled). Use for bulk transfers.

pub fn with_close_behavior(self, behavior: CloseBehavior) -> Self

Set the close behavior.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StreamConfig

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> Self

Returns the “default value” for a type.