pub struct Portforwarder { /* private fields */ }Available on crate feature
client only.Expand description
Manages port-forwarded streams.
Provides AsyncRead + AsyncWrite for each port and does not bind to local ports. Error
channel for each port is only written by the server when there’s an exception and
the port cannot be used (didn’t initialize or can’t be used anymore).
Implementations§
Source§impl Portforwarder
impl Portforwarder
Sourcepub fn take_stream(
&mut self,
port: u16,
) -> Option<impl AsyncRead + AsyncWrite + Unpin + use<>>
pub fn take_stream( &mut self, port: u16, ) -> Option<impl AsyncRead + AsyncWrite + Unpin + use<>>
Take a port stream by the port on the target resource.
A value is returned at most once per port.
Sourcepub fn take_error(
&mut self,
port: u16,
) -> Option<impl Future<Output = Option<String>> + use<>>
pub fn take_error( &mut self, port: u16, ) -> Option<impl Future<Output = Option<String>> + use<>>
Take a future that resolves with any error message or when the error sender is dropped. When the future resolves, the port should be considered no longer usable.
A value is returned at most once per port.
Auto Trait Implementations§
impl !RefUnwindSafe for Portforwarder
impl !UnwindSafe for Portforwarder
impl Freeze for Portforwarder
impl Send for Portforwarder
impl Sync for Portforwarder
impl Unpin for Portforwarder
impl UnsafeUnpin for Portforwarder
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreimpl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Available on crate feature
map-response-body only.Apply a transformation to the response body. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
Available on crate feature
trace only.High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
Available on crate feature
trace only.High level tracing that classifies responses using gRPC headers. Read more