@@ -67,6 +67,8 @@ func (s *streamID) unmarshal(raw string) error {
|
||||
"query is an optional token containing additional information")
|
||||
}
|
||||
|
||||
parts[len(parts)-1] = strings.TrimSuffix(parts[len(parts)-1], "#feedbackplay")
|
||||
|
||||
switch parts[0] {
|
||||
case "read":
|
||||
s.mode = streamIDModeRead
|
||||
|
||||
@@ -58,6 +58,16 @@ func TestStreamIDUnmarshal(t *testing.T) {
|
||||
path: "test3",
|
||||
},
|
||||
},
|
||||
{
|
||||
"issue 5414",
|
||||
"publish:my_path:myuser:mypass#feedbackplay",
|
||||
streamID{
|
||||
mode: streamIDModePublish,
|
||||
path: "my_path",
|
||||
user: "myuser",
|
||||
pass: "mypass",
|
||||
},
|
||||
},
|
||||
} {
|
||||
t.Run(ca.name, func(t *testing.T) {
|
||||
var sid streamID
|
||||
|
||||
Reference in New Issue
Block a user