Initial live/filter work

This commit is contained in:
Daniel 2024-08-05 00:06:57 -04:00
parent a6acdd0ad1
commit 2fc16475d9
2 changed files with 15 additions and 0 deletions

View file

@ -4,6 +4,7 @@ import (
"io"
"sync"
"dynatron.me/x/stillbox/pkg/live"
"dynatron.me/x/stillbox/pkg/pb"
"github.com/rs/zerolog/log"
@ -24,6 +25,7 @@ type client struct {
Connection
live live.Listener
nexus *Nexus
}

13
pkg/live/listener.go Normal file
View file

@ -0,0 +1,13 @@
package live
import (
"dynatron.me/x/stillbox/pkg/pb"
)
type Listener struct {
pb.Live
}
func (l *Listener) IsLive() bool {
return l.State == pb.LiveState_LS_LIVE
}