From 10f28bf6fd6a779113e85a0b052589bb3cc25927 Mon Sep 17 00:00:00 2001 From: Ingo Oppermann Date: Sat, 18 Apr 2020 12:29:17 +0200 Subject: [PATCH] Cosmetics --- examples/rtmp_server/main.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/examples/rtmp_server/main.go b/examples/rtmp_server/main.go index 8d089ef..4977b4a 100644 --- a/examples/rtmp_server/main.go +++ b/examples/rtmp_server/main.go @@ -163,12 +163,14 @@ func (s *server) handlePublish(conn *rtmp.Conn) { return } + metadata := conn.GetMetaData() + s.lock.Lock() ch := s.channels[conn.URL.Path] if ch == nil { ch = &channel{} - ch.metadata = conn.GetMetaData() + ch.metadata = metadata ch.que = pubsub.NewQueue() ch.que.WriteHeader(streams) for _, stream := range streams {