pub async fn create_reader_group_with_config(
        &self,
        reader_group_name: String,
        reader_group_config: ReaderGroupConfig,
        scope: Scope,
    ) -> ReaderGroup {
        info!(
            "Creating reader group {:?} to read data from streams {:?}",
            reader_group_name,
            reader_group_config.get_streams()
        );
        self.client_factory_async
            .create_reader_group_with_config(scope, reader_group_name, reader_group_config)
            .await
    }
///
/// Create a Reader Group based on the ReaderGroupConfig.
///
Create a Reader Group based on the ReaderGroupConfig.
Create a Reader Group based on the ReaderGroupConfig .
pub async fn create_reader_group_with_config(
        &self,
        reader_group_name: String,
        reader_group_config: ReaderGroupConfig,
        scope: Scope,
    ) -> ReaderGroup {
        info!(
            "Creating reader group {:?} to read data from streams {:?}",
            reader_group_name,
            reader_group_config.get_streams()
        );
        self.client_factory_async
            .create_reader_group_with_config(scope, reader_group_name, reader_group_config)
            .await
    }
pub async fn create_reader_group_with_config ( & self , reader_group_name : String , reader_group_config : ReaderGroupConfig , scope : Scope , ) -> ReaderGroup { info ! ( " " reader_group_name reader_group_config get_streams ( ) ) ; self . client_factory_async . create_reader_group_with_config ( scope , reader_group_name , reader_group_config ) . await }
Create a Reader Group based on the ReaderGroupConfig.
Create a Reader Group based on the ReaderGroupConfig .
&self
reader_group_name
String
reader_group_config
ReaderGroupConfig
scope
Scope
&self
reader_group_name
String
reader_group_config
ReaderGroupConfig
scope
Scope