pub(crate) struct Stream {
pub(super) headers: Headers,
pub(super) receiver: StreamReceiver,
pub(super) sender: StreamSender,
}Expand description
A stream the client opened and the server accepted.
Fields§
§headers: Headers§receiver: StreamReceiver§sender: StreamSenderImplementations§
Source§impl Stream
impl Stream
Sourcepub(crate) fn reset_watch(&self) -> WaitForCancellationFutureOwned ⓘ
pub(crate) fn reset_watch(&self) -> WaitForCancellationFutureOwned ⓘ
Resolves once the stream got reset or the connection ended, also after the stream got dropped.
Sourcepub(crate) fn split(self) -> (StreamReceiver, StreamSender)
pub(crate) fn split(self) -> (StreamReceiver, StreamSender)
Split the stream into the data of the client and the sending side, to use both at the same time.
Auto Trait Implementations§
impl Freeze for Stream
impl RefUnwindSafe for Stream
impl Send for Stream
impl Sync for Stream
impl Unpin for Stream
impl UnsafeUnpin for Stream
impl UnwindSafe for Stream
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].