diff --git a/protocol/rtmp/rtmp.go b/protocol/rtmp/rtmp.go index 132ac50..7f2def0 100755 --- a/protocol/rtmp/rtmp.go +++ b/protocol/rtmp/rtmp.go @@ -143,6 +143,7 @@ func (s *Server) handleConn(conn *core.Conn) error { writer := s.getter.GetWriter(reader.Info()) s.handler.HandleWriter(writer) } + //FIXME: should flv should be configurable, not always on -gs flvWriter := new(flv.FlvDvr) s.handler.HandleWriter(flvWriter.GetWriter(reader.Info())) } else {