Struct RelaySessionHandle 

pub struct RelaySessionHandle { /* private fields */ }

Thread-safe generated-binding owner for one serialized relay session.

Implementations

impl RelaySessionHandle

pub fn new() -> Self

Construct an empty disconnected session.

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

Begin a platform-owned WebSocket connection attempt.

Errors

Returns a stable invalid-transition error.

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

Notify the session that the native transport is connected.

Errors

Returns a stable invalid-transition error.

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

Mark relay authentication complete and replay retained intent.

Errors

Returns a stable transition or bounded-queue error.

pub fn subscribe( &self, subscription_id: String, filter_json: Vec<String>, ) -> Result<(), SoftchatError>

Add or replace a subscription using strict filter JSON objects.

Errors

Returns a stable filter, transition, or bounded-queue error.

pub fn close_subscription( &self, subscription_id: String, ) -> Result<(), SoftchatError>

Close one retained subscription.

Errors

Returns a stable state or bounded-queue error.

pub fn publish(&self, events: Vec<SignedEvent>) -> Result<(), SoftchatError>

Queue already-persisted authored events for delivery.

Errors

Returns a stable validation, state, or queue error.

pub fn receive( &self, frame_json: String, ) -> Result<Vec<RelaySessionAction>, SoftchatError>

Consume one complete native WebSocket text frame.

Errors

Returns a stable frame, correlation, state, or backpressure error.

pub fn confirm_ingested(&self, event_id: String) -> Result<(), SoftchatError>

Confirm an authoritative platform transaction handled an event.

Errors

Returns a stable persistence-result error for unknown IDs.

pub fn transport_lost(&self) -> Result<Vec<RelaySessionAction>, SoftchatError>

Handle transport loss and return the reconnect plan.

Errors

Returns a stable invalid-transition error.

pub fn drain_outbound(&self, limit: u32) -> Result<Vec<String>, SoftchatError>

Drain at most limit ordered outbound text frames.

Errors

Returns a stable error for a zero limit.

pub fn snapshot(&self) -> RelaySessionSnapshot

Return one redacted serializable snapshot.

pub fn cancel(&self) -> RelaySessionAction

Permanently cancel the session and clear process-local queues.

Trait Implementations

impl Debug for RelaySessionHandle

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

Formats the value using the given formatter.

impl Default for RelaySessionHandle

fn default() -> Self

Returns the “default value” for a type.

impl<UT> LiftRef<UT> for RelaySessionHandle

type LiftType = Arc<RelaySessionHandle>

impl<UT> LowerError<UT> for RelaySessionHandle

fn lower_error(obj: Self) -> RustBuffer

Lower this value for scaffolding function return

impl<UT> LowerReturn<UT> for RelaySessionHandle

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

The type that should be returned by scaffolding functions for this type.

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

Lower the return value from an scaffolding call

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

Lower the return value for failed argument lifts

impl<UT> TypeId<UT> for RelaySessionHandle

const TYPE_ID_META: MetadataBuffer