Enum StreamCommand 

pub(crate) enum StreamCommand {
    Reset {
        code: u64,
    },
    Inject {
        bytes: Bytes,
    },
}

A request delivered to the task that owns one forwarded stream.

A channel rather than a shared handle because both operations here need &mut SendStream, and the stream is moved by value into its forwarding task on every path this proxy takes. See StreamEntry for the rest of that argument.

Variants

Reset

Abandon this stream: reset the destination with code and stop the source with the same code.

Fields

code: u64

The application error code both peers are given.

Inject

Write these bytes onto this stream at the next point the receiving decoder accepts one.

Only the two control directions ever receive this. A data stream’s task has no notion of a message boundary — it forwards chunks — so it could not honour the “in sequence” half of the request, and nothing routes one to it.

Fields

bytes: Bytes

A complete, framed control message, written verbatim.

Trait Implementations

impl Debug for StreamCommand

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

Formats the value using the given formatter.