Struct Stream 

pub struct Stream { /* private fields */ }

Bidirectional SPDY/3.1 stream pair: a writable “data” stream plus an “error” stream half-closed at open time. The shape suits any peer that uses paired streams (Kubernetes port-forward is one such peer; the multiplexer treats the headers as opaque).

Streams are lazily opened on the wire: MuxHandle::open_stream_pair reserves a session slot and creates the per-stream channels, but no SPDY SYN_STREAM frame is sent until the consumer actually writes its first byte. This avoids the idle-upstream-close race for peers that dial an upstream connection eagerly on SYN_STREAM while preserving the pre-opened spare-stream throughput optimization.

Implements AsyncRead + AsyncWrite on the data half. The error half is available via split().

Implementations

impl Stream

pub fn is_read_closed(&self) -> bool

Returns true if the remote has already closed this stream’s read side (FIN or RST received while idle). Used by spare-stream checkout to discard stale pre-opened streams.

Unopened streams are never stale: no SYN_STREAM was sent yet, so the apiserver hasn’t created a backing pod TCP connection.

pub fn split(self) -> (DataStream, ErrorStream)

Split into data half (AsyncRead + AsyncWrite) and error half (AsyncRead).

Splitting an unopened stream is supported: both halves share a single LazyOpenSlot driven by the data half’s first write.

Trait Implementations

impl AsyncBufRead for Stream

fn poll_fill_buf( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8]>>

Attempts to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

impl AsyncRead for Stream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for Stream

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Unpin for Stream