Struct vtubestudio::service::TungsteniteConnector
source · pub struct TungsteniteConnector;
Available on crate feature
tokio-tungstenite
only.Expand description
A Service
for creating new TungsteniteApiTransport
s.
This is used by tower::reconnect::Reconnect
(used in
ClientBuilder
) for lazily connecting/reconnecting to websockets.
Trait Implementations§
source§impl Clone for TungsteniteConnector
impl Clone for TungsteniteConnector
source§fn clone(&self) -> TungsteniteConnector
fn clone(&self) -> TungsteniteConnector
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for TungsteniteConnector
impl Debug for TungsteniteConnector
source§impl<R> Service<R> for TungsteniteConnector
impl<R> Service<R> for TungsteniteConnector
§type Response = ApiTransport<WebSocketStream<MaybeTlsStream<TcpStream>>, TungsteniteCodec>
type Response = ApiTransport<WebSocketStream<MaybeTlsStream<TcpStream>>, TungsteniteCodec>
Responses given by the service.
§type Future = Pin<Box<dyn Future<Output = Result<<TungsteniteConnector as Service<R>>::Response, <TungsteniteConnector as Service<R>>::Error>> + Send>>
type Future = Pin<Box<dyn Future<Output = Result<<TungsteniteConnector as Service<R>>::Response, <TungsteniteConnector as Service<R>>::Error>> + Send>>
The future response value.
Auto Trait Implementations§
impl Freeze for TungsteniteConnector
impl RefUnwindSafe for TungsteniteConnector
impl Send for TungsteniteConnector
impl Sync for TungsteniteConnector
impl Unpin for TungsteniteConnector
impl UnwindSafe for TungsteniteConnector
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
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<M, T, Target, Request> MakeTransport<Target, Request> for M
impl<M, T, Target, Request> MakeTransport<Target, Request> for M
source§fn poll_ready(
&mut self,
cx: &mut Context<'_>,
) -> Poll<Result<(), <M as MakeTransport<Target, Request>>::MakeError>>
fn poll_ready( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), <M as MakeTransport<Target, Request>>::MakeError>>
Returns
Ready
when the factory is able to create more transports. Read moresource§fn make_transport(
&mut self,
target: Target,
) -> <M as MakeTransport<Target, Request>>::Future
fn make_transport( &mut self, target: Target, ) -> <M as MakeTransport<Target, Request>>::Future
Create and return a new transport asynchronously.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T, Request> ServiceExt<Request> for T
impl<T, Request> ServiceExt<Request> for T
source§fn ready(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
fn ready(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
Yields a mutable reference to the service when it is ready to accept a request.
source§fn ready_and(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
fn ready_and(&mut self) -> Ready<'_, Self, Request>where
Self: Sized,
👎Deprecated since 0.4.6: please use the
ServiceExt::ready
method insteadYields a mutable reference to the service when it is ready to accept a request.
source§fn ready_oneshot(self) -> ReadyOneshot<Self, Request>where
Self: Sized,
fn ready_oneshot(self) -> ReadyOneshot<Self, Request>where
Self: Sized,
Yields the service when it is ready to accept a request.
source§fn oneshot(self, req: Request) -> Oneshot<Self, Request>where
Self: Sized,
fn oneshot(self, req: Request) -> Oneshot<Self, Request>where
Self: Sized,
Consume this
Service
, calling with the providing request once it is ready.source§fn and_then<F>(self, f: F) -> AndThen<Self, F>
fn and_then<F>(self, f: F) -> AndThen<Self, F>
Executes a new future after this service’s future resolves. This does
not alter the behaviour of the
poll_ready
method. Read moresource§fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
Maps this service’s response value to a different value. This does not
alter the behaviour of the
poll_ready
method. Read moresource§fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
Maps this service’s error value to a different value. This does not
alter the behaviour of the
poll_ready
method. Read moresource§fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
Maps this service’s result type (
Result<Self::Response, Self::Error>
)
to a different value, regardless of whether the future succeeds or
fails. Read moresource§fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
Composes a function in front of the service. Read more
source§fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F>
fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F>
Composes an asynchronous function after this service. Read more
source§fn map_future<F, Fut, Response, Error>(self, f: F) -> MapFuture<Self, F>
fn map_future<F, Fut, Response, Error>(self, f: F) -> MapFuture<Self, F>
Composes a function that transforms futures produced by the service. Read more