pub struct NetworkEventHandle { /* private fields */ }Expand description
Network Event Handle
Lightweight handle for sending network events and receiving processing results.
Created before ActrNode::start() to bridge platform network events.
Implementations§
Source§impl NetworkEventHandle
impl NetworkEventHandle
Sourcepub fn new(event_tx: Sender<NetworkEventRequest>) -> Self
pub fn new(event_tx: Sender<NetworkEventRequest>) -> Self
Create a new NetworkEventHandle
Sourcepub fn new_with_result_timeout(
event_tx: Sender<NetworkEventRequest>,
result_timeout: Duration,
) -> Self
pub fn new_with_result_timeout( event_tx: Sender<NetworkEventRequest>, result_timeout: Duration, ) -> Self
Create a new NetworkEventHandle with a custom result timeout.
Production bindings use NetworkEventHandle::new. Tests can use this
constructor to verify bounded waiting without sleeping for the full
binding timeout.
Sourcepub async fn handle_network_path_changed(
&self,
snapshot: NetworkSnapshot,
) -> Result<NetworkEventResult, String>
pub async fn handle_network_path_changed( &self, snapshot: NetworkSnapshot, ) -> Result<NetworkEventResult, String>
Handle full network path changes.
Sourcepub async fn handle_app_lifecycle_changed(
&self,
state: AppLifecycleState,
) -> Result<NetworkEventResult, String>
pub async fn handle_app_lifecycle_changed( &self, state: AppLifecycleState, ) -> Result<NetworkEventResult, String>
Handle app lifecycle changes.
Sourcepub async fn cleanup_connections(
&self,
reason: CleanupReason,
) -> Result<NetworkEventResult, String>
pub async fn cleanup_connections( &self, reason: CleanupReason, ) -> Result<NetworkEventResult, String>
Proactively clean up all connections with a reason. This never reconnects.
Sourcepub async fn force_reconnect(
&self,
reason: ReconnectReason,
) -> Result<NetworkEventResult, String>
pub async fn force_reconnect( &self, reason: ReconnectReason, ) -> Result<NetworkEventResult, String>
Force cleanup and reconnect.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for NetworkEventHandle
impl RefUnwindSafe for NetworkEventHandle
impl Send for NetworkEventHandle
impl Sync for NetworkEventHandle
impl Unpin for NetworkEventHandle
impl UnsafeUnpin for NetworkEventHandle
impl UnwindSafe for NetworkEventHandle
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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