diff --git a/pkg/rtmp/server_session.go b/pkg/rtmp/server_session.go index 0ee2e94..03eb470 100644 --- a/pkg/rtmp/server_session.go +++ b/pkg/rtmp/server_session.go @@ -111,6 +111,11 @@ func (s *ServerSession) Write(msg []byte) error { return err } +func (s *ServerSession) Writev(msgs net.Buffers) error { + _, err := s.conn.Writev(msgs) + return err +} + func (s *ServerSession) Flush() error { return s.conn.Flush() }