pub async fn create_reader_group(&self, reader_group_name: String, stream: ScopedStream) -> ReaderGroup {
        let scope = stream.scope.clone();
        let rg_config = ReaderGroupConfigBuilder::default().add_stream(stream).build();
        ReaderGroup::create(scope, reader_group_name, rg_config, self.clone()).await
    }
///
/// Create a ReaderGroup with the specified name to read from the specified Stream.
/// The readers will read from the HEAD/beginning of the Stream.
///
Create a ReaderGroup with the specified name to read from the specified Stream.
The readers will read from the HEAD/beginning of the Stream.
Create a ReaderGroup with the specified name to read from the specified Stream . The readers will read from the HEAD / beginning of the Stream .
pub async fn create_reader_group(&self, reader_group_name: String, stream: ScopedStream) -> ReaderGroup {
        let scope = stream.scope.clone();
        let rg_config = ReaderGroupConfigBuilder::default().add_stream(stream).build();
        ReaderGroup::create(scope, reader_group_name, rg_config, self.clone()).await
    }
pub async fn create_reader_group ( & self , reader_group_name : String , stream : ScopedStream ) -> ReaderGroup { let scope = stream . scope . clone ( ) ; let rg_config = ReaderGroupConfigBuilder :: default ( ) . add_stream ( stream ) . build ( ) ; ReaderGroup :: create ( scope , reader_group_name , rg_config , self . clone ( ) ) . await }
Create a ReaderGroup with the specified name to read from the specified Stream.
Create a ReaderGroup with the specified name to read from the specified Stream .
&self
reader_group_name
String
stream
ScopedStream
&self
reader_group_name
String
stream
ScopedStream