mirror of
https://github.com/m1k1o/neko.git
synced 2024-07-24 14:40:50 +12:00
fix broadcast bug.
This commit is contained in:
parent
fb6dabf4e0
commit
45f029a2a4
@ -47,7 +47,9 @@ func New(desktop types.DesktopManager, config *config.Capture) *CaptureManagerCt
|
||||
|
||||
func (manager *CaptureManagerCtx) Start() {
|
||||
if manager.BroadcastEnabled() {
|
||||
manager.createBroadcastPipeline()
|
||||
if err := manager.createBroadcastPipeline(); err != nil {
|
||||
manager.logger.Panic().Err(err).Msg("unable to create broadcast pipeline")
|
||||
}
|
||||
}
|
||||
|
||||
manager.desktop.OnBeforeScreenSizeChange(func() {
|
||||
@ -66,7 +68,9 @@ func (manager *CaptureManagerCtx) Start() {
|
||||
}
|
||||
|
||||
if manager.BroadcastEnabled() {
|
||||
manager.createBroadcastPipeline()
|
||||
if err := manager.createBroadcastPipeline(); err != nil {
|
||||
manager.logger.Panic().Err(err).Msg("unable to create broadcast pipeline")
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
@ -97,7 +101,7 @@ func (manager *CaptureManagerCtx) Shutdown() error {
|
||||
}
|
||||
|
||||
if manager.BroadcastEnabled() {
|
||||
manager.createBroadcastPipeline()
|
||||
manager.destroyBroadcastPipeline()
|
||||
}
|
||||
|
||||
manager.emit_stop <- true
|
||||
|
Loading…
Reference in New Issue
Block a user