(streamPath string, pub IPublisher)
| 202 | } |
| 203 | |
| 204 | func (opt *Plugin) Publish(streamPath string, pub IPublisher) error { |
| 205 | puber := pub.GetPublisher() |
| 206 | if puber == nil { |
| 207 | if EngineConfig.LogLang == "zh" { |
| 208 | return errors.New("不是发布者") |
| 209 | } else { |
| 210 | return errors.New("not publisher") |
| 211 | } |
| 212 | } |
| 213 | opt.AssignPubConfig(puber) |
| 214 | return pub.Publish(streamPath, pub) |
| 215 | } |
| 216 | |
| 217 | var ErrStreamNotExist = errors.New("stream not exist") |
| 218 |
nothing calls this directly
no test coverage detected