Crate wmark

Watermark and Closer implementation for implementing transaction.

Structs

AsyncCloser

AsyncCloser holds the two things we need to close a thread and wait for it to finish: a chan to tell the thread to shut down, and a WaitGroup with which to wait for it to finish shutting down.

AsyncStdSpawnerasync-std

A AsyncSpawner that uses the async-std runtime.

AsyncWaterMarkfuture

WaterMark is used to keep track of the minimum un-finished index. Typically, an index k becomes finished or “done” according to a WaterMark once done(k) has been called

Closer

Closer holds the two things we need to close a thread and wait for it to finish: a chan to tell the thread to shut down, and a WaitGroup with which to wait for it to finish shutting down.

SmolSpawnersmol

A AsyncSpawner that uses the smol runtime.

TokioSpawnertokio and future

A AsyncSpawner that uses the tokio runtime.

WasmSpawnerwasm

A AsyncSpawner that uses the wasm-bindgen-futures runtime.

WaterMark

WaterMark is used to keep track of the minimum un-finished index. Typically, an index k becomes finished or “done” according to a WaterMark once done(k) has been called

Enums

WaterMarkError

Error type for watermark.

Traits

AsyncSpawnerfuture

A spawner trait for spawning futures.

Detachfuture

Detaches the task related to the join handle to let it keep running in the background.