syndication: don't syndicate unpublished streams · stream.place/streamplace@bcc253f

stream.place / streamplace

fork atom

Live video on the AT Protocol

fork atom

syndication: don't syndicate unpublished streams

Eli Mallon 2 weeks ago bcc253f5 1742699a

1 changed file

expand all

unified split

pkg

spxrpc

place_stream_live.go

pkg/spxrpc/place_stream_live.go

··· 193 193 log.Debug(ctx, "exiting segment reader") 194 194 return 195 195 case file := <-segChan.C: 196 + if !file.Published { 197 + continue 198 + } 196 199 log.Debug(ctx, "got segment", "file", file.Filepath) 197 200 err := ws.WriteMessage(websocket.BinaryMessage, file.Data) 198 201 if err != nil {