Struct Subscriber

subscriber.go:131–136

Subscriber 订阅者实体定义

// Subscriber 订阅者实体定义
type Subscriber struct {
	IO
	Config      *config.Subscribe
	readers     []*track.AVRingReader
	TrackPlayer `json:"-" yaml:"-"`
}

func (s *Subscriber) Subscribe(streamPath string, sub ISubscriber) error {
	return s.receive(streamPath, sub)