NewStreamManager creates a new stream manager for the given proto ID.

ErrStreamAlreadyRemoved is the error that a stream has already been removed.

Config is the config for stream manager.

EvtStreamAdded is the event of adding a new stream.

EvtStreamAdded is the event of adding a new stream.

Operator handles new stream or remove stream.

Reader is the interface to read stream in stream manager.

ReaderSubscriber reads stream and subscribe stream events.

StreamManager is the interface for streamManager.

Subscriber is the interface to support stream event subscription.