Skip to main content

spawn

nodedb_lite::sync::array::ack_sender

Function spawn 

Source 
pub fn spawn<S: StorageEngine + 'static>(
    schemas: Arc<SchemaRegistry<S>>,
    engine: Arc<LiteApplyEngine<S>>,
    replica_id: ReplicaId,
    tx: Sender<Vec<u8>>,
    interval: Duration,
    stop: Receiver<()>,
) -> JoinHandle<()> ⓘ
Expand description

Periodic array ack sender task.

Spawned on session connect and cancelled on disconnect. The returned JoinHandle should be stored by the session and aborted (via handle.abort()) on session teardown.