async fn wait_for_read_timestamp( oracle: &(dyn TimestampOracle<Timestamp> + Send + Sync), timestamp: Timestamp, cancel: &mut Receiver<()>, ) -> Result<bool, AdapterError>