Method SubscribeBlock

plugin.go:258–263

SubscribeBlock 阻塞订阅一个流，直到订阅结束

(streamPath string, sub ISubscriber, t byte)

// SubscribeBlock 阻塞订阅一个流，直到订阅结束
func (opt *Plugin) SubscribeBlock(streamPath string, sub ISubscriber, t byte) (err error) {
	if err = opt.Subscribe(streamPath, sub); err == nil {
		sub.PlayBlock(t)
	}
	return
}

var ErrNoPullConfig = errors.New("no pull config")
var Pullers sync.Map