diff --git a/server.go b/server.go index 965848f..f37ba8e 100644 --- a/server.go +++ b/server.go @@ -5,7 +5,6 @@ import ( "context" "errors" "fmt" - "gopkg.in/yaml.v3" "log/slog" "net" "net/http" @@ -16,6 +15,8 @@ import ( "strings" "time" + "gopkg.in/yaml.v3" + "github.com/gobwas/ws" "github.com/gobwas/ws/wsutil" "github.com/shirou/gopsutil/v4/cpu" @@ -407,9 +408,11 @@ func (s *Server) Start() (err error) { if grpcServer != nil { s.AddTask(grpcServer, s.Logger) } - s.Streams.OnStart(func() { - s.Streams.AddTask(&CheckSubWaitTimeout{s: s}) - }) + if s.PulseInterval > 0 { + s.Streams.OnStart(func() { + s.Streams.AddTask(&CheckSubWaitTimeout{s: s}) + }) + } s.loadAdminZip() // s.Transforms.AddTask(&TransformsPublishEvent{Transforms: &s.Transforms}) s.Info("server started")