Struct SpdyStreams 

pub(crate) struct SpdyStreams {
    error: Stream,
    stdin: Option<Stream>,
    stdout: Option<Stream>,
    stderr: Option<Stream>,
    resize: Option<Stream>,
}

The streams of a SPDY session, which the client opened until the session started.

Fields

error: Stream

stdin: Option<Stream>

stdout: Option<Stream>

stderr: Option<Stream>

resize: Option<Stream>

Implementations

impl SpdyStreams

pub(crate) fn accept(headers: &Headers, version: Version) -> Result<()>

Whether the client may open a stream, by its headers.

pub(crate) async fn wait( connection: &mut Connection, expected: ExpectedStreams, ) -> Result<Self>

Wait for the streams the session expects, others may come along. Nothing reads the streams meanwhile: a client which sends more stdin than a stream queues before it opened the others holds up the connection until this times out. client-go opens all streams first.

pub(crate) async fn into_parts( self, connection: Connection, version: Version, ) -> (SpdyInput, SpdyOutput)

The input and the output of the session. The server sends nothing on the streams of the client. The sending side of stdin stays open, a client takes its end as the end of stdin, except for v1 like for the kubelet. The other sending sides get closed.