From 4ad20c8a651c7214a2c1d52ed3b83cffb63d8fed Mon Sep 17 00:00:00 2001 From: nareix Date: Sun, 17 Jul 2016 11:15:18 +0800 Subject: [PATCH] rtmp: expose SplitPath --- format/rtmp/rtmp.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/format/rtmp/rtmp.go b/format/rtmp/rtmp.go index d9bdc01..ecb987c 100644 --- a/format/rtmp/rtmp.go +++ b/format/rtmp/rtmp.go @@ -275,19 +275,19 @@ func (self *Conn) pollMsg() (err error) { } } -func splitPath(u *url.URL) (app, url string) { +func SplitPath(u *url.URL) (app, stream string) { pathsegs := strings.SplitN(u.RequestURI(), "/", 3) if len(pathsegs) > 1 { app = pathsegs[1] } if len(pathsegs) > 2 { - url = pathsegs[2] + stream = pathsegs[2] } return } func getTcUrl(u *url.URL) string { - app, _ := splitPath(u) + app, _ := SplitPath(u) nu := *u nu.Path = "/"+app return nu.String() @@ -592,7 +592,7 @@ func (self *Conn) connect(path string) (err error) { } func (self *Conn) connectPublish() (err error) { - connectpath, publishpath := splitPath(self.URL) + connectpath, publishpath := SplitPath(self.URL) if err = self.connect(connectpath); err != nil { return @@ -651,7 +651,7 @@ func (self *Conn) connectPublish() (err error) { } func (self *Conn) connectPlay() (err error) { - connectpath, playpath := splitPath(self.URL) + connectpath, playpath := SplitPath(self.URL) if err = self.connect(connectpath); err != nil { return