Compare commits
No commits in common. "0d8ecc64adbeb7a487fdec577d0fe46cda26bbb1" and "f8dce5ce9d100b76653226626553ea7c67655759" have entirely different histories.
0d8ecc64ad
...
f8dce5ce9d
|
@ -17,8 +17,6 @@ type Channel struct {
|
||||||
OutputStreams map[string]*media.MediaStream
|
OutputStreams map[string]*media.MediaStream
|
||||||
|
|
||||||
Events *pubsub.PubSub
|
Events *pubsub.PubSub
|
||||||
|
|
||||||
lastMetadata map[string]string
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (channel *Channel) AddInputStream(id string) *media.MediaStream {
|
func (channel *Channel) AddInputStream(id string) *media.MediaStream {
|
||||||
|
@ -52,7 +50,6 @@ func (channel *Channel) AddOutputContainer(id string) *media.MediaStreamContaine
|
||||||
}
|
}
|
||||||
|
|
||||||
func (channel *Channel) SetMetadata(data map[string]string) {
|
func (channel *Channel) SetMetadata(data map[string]string) {
|
||||||
channel.lastMetadata = data
|
|
||||||
channel.Events.Pub(data, "metadata")
|
channel.Events.Pub(data, "metadata")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -60,9 +57,6 @@ func (channel *Channel) Metadata() chan map[string]string {
|
||||||
outC := make(chan map[string]string)
|
outC := make(chan map[string]string)
|
||||||
go func() {
|
go func() {
|
||||||
defer close(outC)
|
defer close(outC)
|
||||||
if channel.lastMetadata != nil {
|
|
||||||
outC <- channel.lastMetadata
|
|
||||||
}
|
|
||||||
c := channel.Events.Sub("metadata")
|
c := channel.Events.Sub("metadata")
|
||||||
forloop:
|
forloop:
|
||||||
for event := range c {
|
for event := range c {
|
||||||
|
|
|
@ -21,9 +21,6 @@ func NewServer() *Server {
|
||||||
Router: gin.New(),
|
Router: gin.New(),
|
||||||
}
|
}
|
||||||
|
|
||||||
server.Router.Use(gin.Logger())
|
|
||||||
server.Router.Use(gin.Recovery())
|
|
||||||
|
|
||||||
server.Http.Handler = server.Router
|
server.Http.Handler = server.Router
|
||||||
server.Http.Addr = ":8000"
|
server.Http.Addr = ":8000"
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue