Struct SpdyInput 

pub(crate) struct SpdyInput {
    stdin: Option<StreamReceiver>,
    peer_closed: Arc<AtomicBool>,
    resize: Option<StreamReceiver>,
    resize_events: ResizeEvents,
    connection: Option<Connection>,
    pub(super) done: CancellationToken,
}

The input of a SPDY client: the stdin stream, whose end closes stdin, and the resize stream, which carries consecutive JSON objects. Clients open a resize stream only with a terminal, which the server does not know for an attach, so it may also come after the session started. Both get read together: once the stdin which the process does not read fills PENDING_STDIN_MAX_BYTES of the session, the resizes wait as well.

Fields

stdin: Option<StreamReceiver>

peer_closed: Arc<AtomicBool>

Set once the client closed its stdin cleanly, so that the output, which fails once the connection ended, does not end the session before the stdin got forwarded, see Output. The end of the connection is a clean close then, which still forwards the stdin the client sent before.

resize: Option<StreamReceiver>

resize_events: ResizeEvents

connection: Option<Connection>

The connection, for the streams which come after the start, see SpdyInput::late_stream.

done: CancellationToken

Cancelled once the connection ended.

Implementations

impl SpdyInput

fn late_stream(&mut self, stream: Stream)

Take a stream which comes after the start: the resize stream, and output streams the session does not use, which end right away, like stderr which clients open for a terminal without asking for one. Others get reset. Nothing gets awaited, the caller may cancel ClientInput::next.

Trait Implementations

impl ClientInput for SpdyInput

async fn next(&mut self) -> Option<ClientEvent>

The next event, None once the client went away without a clean close.

fn answer_close(&mut self) -> impl Future<Output = ()> + Send

Answer the clean close of the client, see web::answer_close.

fn drain(self, output: Output) -> impl Future<Output = ()> + Send

where Self: Sized,

End the connection once output closed it after ClientEvent::TooLarge, see web::drain.