consumer

type BaseStreamConnection struct {
	// contains filtered or unexported fields
}

type StreamConnection interface {
	GetID() string
	GetType() consts.StreamType
	GetOutputChan(consts.Quality) (<-chan []byte, error)
	HandleStream(consts.Quality) error
	AddConnection(consts.Quality, interface{}) error
	Close(consts.Quality) error
	IsOpen() bool
}

type StreamConsumer interface {
	Start() error
	GetStream(streamID string) (StreamConnection, error)
	Stop() error
}