File tree Expand file tree Collapse file tree 2 files changed +4
-9
lines changed Expand file tree Collapse file tree 2 files changed +4
-9
lines changed Original file line number Diff line number Diff line change @@ -80,10 +80,9 @@ impl Producer {
8080 // Check local tracks first, and serve from local if possible
8181 if let Some ( mut local) = self . locals . route ( & subscribed. track_namespace ) {
8282 // Pass the full requested namespace, not the announced prefix
83- if let Some ( track) = local. subscribe (
84- subscribed. track_namespace . clone ( ) ,
85- & subscribed. track_name ,
86- ) {
83+ if let Some ( track) =
84+ local. subscribe ( subscribed. track_namespace . clone ( ) , & subscribed. track_name )
85+ {
8786 log:: info!( "serving subscribe from local: {:?}" , track. info) ;
8887 return Ok ( subscribed. serve ( track) . await ?) ;
8988 }
Original file line number Diff line number Diff line change @@ -84,11 +84,7 @@ impl TracksWriter {
8484 }
8585
8686 /// Remove a track from the broadcast by full name.
87- pub fn remove (
88- & mut self ,
89- namespace : & TrackNamespace ,
90- track_name : & str ,
91- ) -> Option < TrackReader > {
87+ pub fn remove ( & mut self , namespace : & TrackNamespace , track_name : & str ) -> Option < TrackReader > {
9288 let full_name = FullTrackName {
9389 namespace : namespace. clone ( ) ,
9490 name : track_name. to_owned ( ) ,
You can’t perform that action at this time.
0 commit comments