diff --git a/pkg/gordio/nexus/client.go b/pkg/gordio/nexus/client.go index ec18050..4801343 100644 --- a/pkg/gordio/nexus/client.go +++ b/pkg/gordio/nexus/client.go @@ -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 } diff --git a/pkg/live/listener.go b/pkg/live/listener.go new file mode 100644 index 0000000..d17242b --- /dev/null +++ b/pkg/live/listener.go @@ -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 +}