go_zoom_kinesis::client

Trait KinesisClientTestExt

source
pub trait KinesisClientTestExt: KinesisClientTrait {
    // Provided methods
    fn mock_list_shards(
        &self,
        _response: Result<Vec<Shard>>,
    ) -> impl Future<Output = ()> + Send { ... }
    fn mock_get_iterator(
        &self,
        _response: Result<String>,
    ) -> impl Future<Output = ()> + Send { ... }
    fn mock_get_records(
        &self,
        _response: Result<(Vec<Record>, Option<String>)>,
    ) -> impl Future<Output = ()> + Send { ... }
    fn get_iterator_request_count(&self) -> impl Future<Output = usize> + Send { ... }
}

Provided Methods§

source

fn mock_list_shards( &self, _response: Result<Vec<Shard>>, ) -> impl Future<Output = ()> + Send

source

fn mock_get_iterator( &self, _response: Result<String>, ) -> impl Future<Output = ()> + Send

source

fn mock_get_records( &self, _response: Result<(Vec<Record>, Option<String>)>, ) -> impl Future<Output = ()> + Send

source

fn get_iterator_request_count(&self) -> impl Future<Output = usize> + Send

Object Safety§

This trait is not object safe.

Implementors§