run

abstract suspend fun run()

Reads the corresponding partition.

This method gets called at most once.

This method is suspendable and may be cancelled due to a timeout. Implementations must be careful to always make at least some forward progress (according to the value returned by checkpoint) regardless of timeouts.