pub async fn create_stream(&self, subject: &str, name: &str) -> Result<()> {
            let req = CreateStreamRequest {
                subject: subject.to_string(),
                name: name.to_string(),
                ..Default::default()
            };
            self.request(Request::CreateStream(req)).await?;
            Ok(())
        }
//TODO: This is subject to change as it needs to receive StreamOptions
This is subject to change as it needs to receive StreamOptions
This is subject to change as it needs to receive StreamOptions
pub async fn create_stream(&self, subject: &str, name: &str) -> Result<()> {
            let req = CreateStreamRequest {
                subject: subject.to_string(),
                name: name.to_string(),
                ..Default::default()
            };
            self.request(Request::CreateStream(req)).await?;
            Ok(())
        }
pub async fn create_stream ( & self , subject : & str , name : & str ) -> Result < ( ) > { let req = CreateStreamRequest { subject : subject . to_string ( ) , name : name . to_string ( ) , .. Default :: default ( ) } ; self . request ( Request :: CreateStream ( req ) ) . await ? ; Ok ( ( ) ) }
TODO: This is subject to change as it needs to receive StreamOptions
TODO : This is subject to change as it needs to receive StreamOptions
&self
subject
&str
name
&str
&self
subject
&str
name
&str