Expand description
Watermark
and Closer
implementation for implementing transaction.
Structs§
- 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.
- AsyncStdSpawner
async-std
AAsyncSpawner
that uses theasync-std
runtime. - AsyncWaterMark
future
WaterMark is used to keep track of the minimum un-finished index. Typically, an index k becomes finished or “done” according to a WaterMark oncedone(k)
has been called - 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.
- SmolSpawner
smol
AAsyncSpawner
that uses thesmol
runtime. - TokioSpawner
tokio
andfuture
AAsyncSpawner
that uses thetokio
runtime. - WasmSpawner
wasm
AAsyncSpawner
that uses thewasm-bindgen-futures
runtime. - 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§
- Error type for watermark.
Traits§
- AsyncSpawner
future
A spawner trait for spawning futures. - Detach
future
Detaches the task related to the join handle to let it keep running in the background.