def__init__(self,name:str,*args:Any,declare:bool=True,**kwargs:Any,)->None:"""Initialize the JetStream stream. Args: name: The stream name. *args: The arguments. declare: Whether to declare the stream. **kwargs: The keyword arguments. """super().__init__(name=name,declare=declare,subjects=[],config=StreamConfig(*args,name=name,**kwargs,# type: ignore[misc]),)
@classmethoddefvalidate(cls:Type[NameRequiredCls],value:Union[str,NameRequiredCls,None],**kwargs:Any,)->Optional[NameRequiredCls]:"""Validates a value. Args: value: The value to be validated. **kwargs: Additional keyword arguments. Returns: The validated value. """ifvalueisnotNoneandisinstance(value,str):value=cls(value,**kwargs)returnvalue