pub(super) struct ClientRx {
stdin: Receiver<Stdin>,
resize: Receiver<Option<Bytes>>,
too_large: CancellationToken,
stdin_taken: Activity,
}Expand description
What the input of a client hands to the loop of its session.
Fields§
§stdin: Receiver<Stdin>§resize: Receiver<Option<Bytes>>§too_large: CancellationTokenCancelled once the client sent a message larger than the server takes, which fails the session.
stdin_taken: ActivityTouched whenever the container took a part of the stdin, at the clean
close of the client, and while the runtime starts an exec process
with stdin.
The stdin before the close gets forwarded until the container did not
take any of it for STDIN_FLUSH_TIMEOUT.
Auto Trait Implementations§
impl Freeze for ClientRx
impl RefUnwindSafe for ClientRx
impl Send for ClientRx
impl Sync for ClientRx
impl Unpin for ClientRx
impl UnsafeUnpin for ClientRx
impl UnwindSafe for ClientRx
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].