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_unregister_request<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
reason: Option<String>,
) -> Pin<Box<dyn Future<Output = NetworkResult<UnregisterResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_unregister_request<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
reason: Option<String>,
) -> Pin<Box<dyn Future<Output = NetworkResult<UnregisterResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Send UnregisterRequest to signaling server (Actr → Signaling flow) Read more
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<Pong>> + 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<Pong>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Send center skip（Registerafter stream process, using ActrToSignaling）
Returns Pong response if received, error if timeout or no response
Source§fn send_route_candidates_request<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
request: RouteCandidatesRequest,
) -> Pin<Box<dyn Future<Output = NetworkResult<RouteCandidatesResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_route_candidates_request<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
request: RouteCandidatesRequest,
) -> Pin<Box<dyn Future<Output = NetworkResult<RouteCandidatesResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Send RouteCandidatesRequest (requires authenticated Actor session)
Source§fn send_credential_update_request<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
) -> Pin<Box<dyn Future<Output = NetworkResult<RegisterResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_credential_update_request<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
credential: AIdCredential,
) -> Pin<Box<dyn Future<Output = NetworkResult<RegisterResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Send CredentialUpdateRequest to refresh the Actor’s credential Read more
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
Source§fn subscribe_state(&self) -> Receiver<ConnectionState>
fn subscribe_state(&self) -> Receiver<ConnectionState>
Subscribe to connection state changes (Connected/Disconnected).
Source§fn set_actor_id<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn set_actor_id<'life0, 'async_trait>(
&'life0 self,
actor_id: ActrId,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Set actor ID and credential state for reconnect URL parameters.
fn set_credential_state<'life0, 'async_trait>(
&'life0 self,
credential_state: CredentialState,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
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