pub struct WebSocketSignalingClient { /* private fields */ }Expand description
WebSocket signaling clientImplementation
Implementations§
Source§impl WebSocketSignalingClient
impl WebSocketSignalingClient
Sourcepub fn new(config: SignalingConfig) -> Self
pub fn new(config: SignalingConfig) -> Self
Create new WebSocket signaling client
Sourcepub async fn connect_to(url: &str) -> NetworkResult<Self>
pub async fn connect_to(url: &str) -> NetworkResult<Self>
simple for convenience construct create Function
Trait Implementations§
Source§impl SignalingClient for WebSocketSignalingClient
impl SignalingClient for WebSocketSignalingClient
Source§fn connect<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn connect<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Connecttosignaling server
Source§fn disconnect<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn disconnect<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
DisconnectConnect
Source§fn send_register_request<'life0, 'async_trait>(
&'life0 self,
request: RegisterRequest,
) -> Pin<Box<dyn Future<Output = NetworkResult<RegisterResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_register_request<'life0, 'async_trait>(
&'life0 self,
request: RegisterRequest,
) -> Pin<Box<dyn Future<Output = NetworkResult<RegisterResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
SendRegisterrequest（Register front stream process ，using PeerToSignaling）
Source§fn send_heartbeat<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
availability: ServiceAvailabilityState,
power_reserve: f32,
mailbox_backlog: f32,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_heartbeat<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
availability: ServiceAvailabilityState,
power_reserve: f32,
mailbox_backlog: f32,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Send center skip（Registerafter stream process ，using ActrToSignaling）
Source§fn send_envelope<'life0, 'async_trait>(
&'life0 self,
envelope: SignalingEnvelope,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_envelope<'life0, 'async_trait>(
&'life0 self,
envelope: SignalingEnvelope,
) -> Pin<Box<dyn Future<Output = NetworkResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Sendsignalingsignal seal （ pass usage Method）
Source§fn receive_envelope<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = NetworkResult<Option<SignalingEnvelope>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn receive_envelope<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = NetworkResult<Option<SignalingEnvelope>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Receivesignalingsignal seal
Source§fn is_connected(&self) -> bool
fn is_connected(&self) -> bool
Check connection status
Source§fn get_stats(&self) -> SignalingStats
fn get_stats(&self) -> SignalingStats
GetConnect statistics info
Auto Trait Implementations§
impl !Freeze for WebSocketSignalingClient
impl !RefUnwindSafe for WebSocketSignalingClient
impl Send for WebSocketSignalingClient
impl Sync for WebSocketSignalingClient
impl Unpin for WebSocketSignalingClient
impl !UnwindSafe for WebSocketSignalingClient
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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<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 more