(self, listen_for)
return stream_names
Convert a list of api names & event names into stream names

        The format of these names will vary based on the stream_use setting.
Convert a list of api names & event names into stream names
Convert a list of api names & event names into stream names
def _get_stream_names(self, listen_for):
        """Convert a list of api names & event names into stream names

        The format of these names will vary based on the stream_use setting.
        """
        stream_names = []
        for api_name, event_name in listen_for:
            if self.stream_use == StreamUse.PER_EVENT:
                stream_name = f"{api_name}.{event_name}:stream"
            elif self.stream_use == StreamUse.PER_API:
                stream_name = f"{api_name}.*:stream"
            else:
                raise ValueError(
                    "Invalid value for stream_use config option. This should have been caught "
                    "during config validation."
                )
            if stream_name not in stream_names:
                stream_names.append(stream_name)
        return stream_names
def _get_stream_names ( self , listen_for ) : stream_names = [ ] for api_name , event_name in listen_for : if self . stream_use == StreamUse . PER_EVENT : stream_name = f"{api_name}.{event_name}:stream" elif self . stream_use == StreamUse . PER_API : stream_name = f"{api_name}.*:stream" else : raise ValueError ( "Invalid value for stream_use config option. This should have been caught " "during config validation." ) if stream_name not in stream_names : stream_names . append ( stream_name ) return stream_names