Skip to main content

ManagedAccountTransport

Struct ManagedAccountTransport 

Source
pub struct ManagedAccountTransport { /* private fields */ }
Expand description

SDK-owned WSS/Noise executor for one crate::SoftchatAccount.

Each instance owns one named OS thread with a current-thread Tokio runtime. It drives the same correlated account transport actions exposed by the low-level API, so protocol, delivery, retry, authentication, and sync truth remain in one Rust state machine.

Implementations§

Source§

impl ManagedAccountTransport

Source

pub fn new(account: Arc<AccountRuntimeHandle>) -> Result<Self, SoftchatError>

Start the only active managed or low-level transport for this account.

§Errors

Returns a stable account, relay, persistence, or worker-start error.

Source

pub fn snapshot(&self) -> ManagedTransportSnapshot

Return the latest non-blocking state snapshot.

Source

pub fn wait_for_update( &self, after_sequence: u64, timeout_millis: u64, ) -> ManagedTransportSnapshot

Block for a newer snapshot or the bounded timeout.

This is intended for authored language facades to adapt to Flow or an equivalent async stream on a background dispatcher.

Source

pub fn wake(&self)

Coalesce an immediate durable-revision wake hint.

The worker also checks revision-backed work every 250 ms, so direct Rust consumers do not need to implement a notifier for correctness.

Source

pub fn set_network_available(&self, available: bool)

Update the host reachability hint.

Source

pub fn force_resync(&self) -> Result<(), SoftchatError>

Forget synchronization checkpoints and reconnect from retained truth.

§Errors

Returns a stable account/synchronization error or a redacted worker failure when the command cannot be completed within 30 seconds.

Source

pub fn flush(&self, timeout_millis: u64) -> Result<bool, SoftchatError>

Wait until work committed before this call is delivered and sync is idle.

Returns false on timeout, disconnection, or shutdown.

§Errors

Returns a stable account error when the account is already closed.

Source

pub fn shutdown(&self)

Stop the worker, close the socket, release leases, and join its thread.

Repeated calls are harmless.

Trait Implementations§

Source§

impl Debug for ManagedAccountTransport

Source§

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Drop for ManagedAccountTransport

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)
Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned. Read more
Source§

impl<UT> LiftRef<UT> for ManagedAccountTransport

Source§

impl<UT> LowerError<UT> for ManagedAccountTransport

Source§

fn lower_error(obj: Self) -> RustBuffer

Lower this value for scaffolding function return Read more
Source§

impl<UT> LowerReturn<UT> for ManagedAccountTransport

Source§

type ReturnType = <Arc<ManagedAccountTransport> as LowerReturn<UniFfiTag>>::ReturnType

The type that should be returned by scaffolding functions for this type. Read more
Source§

fn lower_return(obj: Self) -> Result<Self::ReturnType, RustCallError>

Lower the return value from an scaffolding call Read more
§

fn handle_failed_lift( error: LiftArgsError, ) -> Result<Self::ReturnType, RustCallError>

Lower the return value for failed argument lifts Read more
Source§

impl<UT> TypeId<UT> for ManagedAccountTransport

Source§

const TYPE_ID_META: MetadataBuffer

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T, UT> HandleAlloc<UT> for T
where T: Send + Sync,

§

fn new_handle(value: Arc<T>) -> Handle

Create a new handle for an Arc value Read more
§

unsafe fn clone_handle(handle: Handle) -> Handle

Clone a handle Read more
§

unsafe fn consume_handle(handle: Handle) -> Arc<T>

Consume a handle, getting back the initial Arc<> Read more
§

unsafe fn get_arc(handle: Handle) -> Arc<Self>

Get a clone of the Arc<> using a “borrowed” handle. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,