Struct AlwaysResume 

pub struct AlwaysResume;

A resume policy that resumes regardless of the error type.

This may be useful in tests, or if used with a very low limit on the number of allowed failures.

Example

let policy = AlwaysResume.with_attempt_limit(3);
assert!(matches!(policy.on_error(&ResumeQuery::new(0), scary_error()), ResumeResult::Continue(_)));
assert!(matches!(policy.on_error(&ResumeQuery::new(1), scary_error()), ResumeResult::Continue(_)));
assert!(matches!(policy.on_error(&ResumeQuery::new(2), scary_error()), ResumeResult::Continue(_)));
assert!(matches!(policy.on_error(&ResumeQuery::new(3), scary_error()), ResumeResult::Exhausted(_)));

use google_cloud_gax::error::{Error, rpc::Code, rpc::Status};
fn scary_error() -> Error {
   // ... details omitted ...
}

Trait Implementations

impl Debug for AlwaysResume

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ReadResumePolicy for AlwaysResume

fn on_error(&self, _status: &ResumeQuery, error: Error) -> ResumeResult

Determines if the read should continue after an error.