Struct OnDisconnect 

pub struct OnDisconnect { /* private fields */ }

Async handle for scheduling writes that run when the client disconnects.

Mirrors the surface of the JS SDK (packages/database/src/api/OnDisconnect.ts). Operations resolve server value placeholders before being sent to the realtime backend and require an active WebSocket transport for full server-side semantics. When the runtime falls back to the HTTP long-poll transport the commands are queued locally and flushed when Database::go_offline() runs, which preserves graceful shutdowns but cannot detect abrupt connection loss.

Implementations

impl OnDisconnect

pub async fn set<V>(&self, value: V) -> DatabaseResult<()>

where V: Into<Value>,

Schedules a write for when the client disconnects.

Mirrors OnDisconnect.set() from the JS SDK. The payload is normalised using the same server timestamp/increment resolution as immediate writes so placeholders resolve against the current backend value.

pub async fn set_with_priority<V, P>( &self, value: V, priority: P, ) -> DatabaseResult<()>

where V: Into<Value>, P: Into<Value>,

Schedules a write together with its priority for disconnect.

pub async fn update( &self, updates: JsonMap<String, Value>, ) -> DatabaseResult<()>

Schedules an update when the client disconnects.

pub async fn remove(&self) -> DatabaseResult<()>

Ensures the value at this location is deleted when the client disconnects.

pub async fn cancel(&self) -> DatabaseResult<()>

Cancels all pending on-disconnect operations.

Trait Implementations

impl Clone for OnDisconnect

fn clone(&self) -> OnDisconnect

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OnDisconnect

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

Formats the value using the given formatter.